Grails, Grails RabbitMQ plugin, Java ,Spring AMQP - Multiple clients -
मैंने सरल Grails REST वेब सेवा विकसित की है जो Grails RabbitMQ प्लगइन का उपयोग करती है और कतार में संदेश भेजती है।
Grails - Config.groovy
क्यूज = {विनिमय नाम: 'my.topic', प्रकार: विषय, टिकाऊ: गलत, {foo टिकाऊ: सही, बाइंडिंग: मेरे जावा डेस्कटॉप ऐप पर मैं स्प्रिंग एएमक्यूपी का उपयोग करके उस संदेश को सुनने की कोशिश करता हूं। मुख्य जावा। सार्वजनिक स्थिर शून्य मुख्य (स्ट्रिंग [] आर्ग्स) {CachingConnectionFactory सीएफ = नया कैशिंग कनेक्शन Factory ("स्थानीयहोस्ट"); cf.setUsername ( "अतिथि"); cf.setPassword ( "अतिथि"); RabbitAdmin व्यवस्थापक = नए RabbitAdmin (सीएफ); SimpleMessageListenerContainer कंटेनर = नया SimpleMessageListenerContainer (सीएफ); ऑब्जेक्ट श्रोता = नया ऑब्जेक्ट () {सार्वजनिक शून्य मैसेज (स्ट्रिंग फू) {System.out.println (foo); }}; MessageListenerAdapter एडाप्टर = नया MessageListenerAdapter (श्रोता); container.setMessageListener (अनुकूलक); container.setQueueNames ( "foo"); container.start (); }
जब मैं एक से अधिक क्लाइंट चलाता हूं (दो कहते हैं) कभी-कभी एक बार "संदेश" प्राप्त होता है, कभी-कभी दूसरे। दोनों ग्राहक "संदेश" पर "संदेश" कैसे प्राप्त कर सकते हैं (मैं पेज पुनः लोड करके मेरी इंडेक्स Grails नियंत्रक से संदेश भेजता है)।
ऐसा करने के लिए किस तरह से पसंदीदा तरीका है? मैं न्यूबी हूं:)
प्रत्येक उपभोक्ता को अपनी ही कतार की ज़रूरत है एक्सचेंज में।
< P> एक ही कतार में एकाधिक उपभोक्ता संदेश के लिए प्रतिस्पर्धा करते हैं।
Comments
Post a Comment