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

Popular posts from this blog

python - Strange behavior using PyQt4's 'pyqtSlot' decorator before another decorator -

-
I have a strange problem with using the QtCore.pyqtSlot decorator in front of the function decorated with a different decorator. The problem below shows this problem, it immediately provides a low QT program with a single button. When pressing a button, the following happens: (1) The signal 'signal_A' and 'signal_B' sequence are connected to method_A and method_B ​​respectively. (2) signal_A and signal_B signals are emitted. (3) The required behavior is that the method_A and method_B ​​are executed. However, it turns out that both signal_A and signal_B trigger method_A, or method_B ​​(oddly, this is nondeterministic, and different for each part of the program!). It appears to be a bug. This issue is present when PyQt4 binding is used in Qt. It is not present when using PySide (use the '-pyside' parameter to verify) I have seen both problems in Python 2 and 3, and both in Windows and Linux This issue is related to the insertion of a decorator be...
Read more

c# - UnhandledExceptionMode.ThrowException for AppDomain.UnhandledException -

-
I want to set unhandledExceptionMode.ThrowException for current AppDomain and not only for application threads. An exception from the second thread should also be handled by my current Donan_Unimated exception handler. Is it possible? Here's my code: Fixed class program {/// & lt; Summary & gt; Main entry point for the application /// & lt; / Summary & gt; [STAThread] static zero major () {applications Set unhandled exception mode (unwanted exception. Throws up); AppDomain.CurrentDomain.UnhandledException + = New UnrestrictedExceptionEndception (CurrentDomain_UnhandledException); Application.EnableVisualStyles (); Application.SetCompatibleTextRenderingDefault (wrong); Application.Run (New Form 1 ()); } Static Zero CurrentDomain_UnhandledException (Object Sender, UnhandledExceptionEventArgs E) {File.AppendAllText ("Log.txt", (Exception) e.ExceptionObject). Message + environment. Newline); }} Maybe you search for the behavior provided by Applic...
Read more

c# - Process.Kill() returns access denied -

-
I'm trying to kill a process using a CMD command line from my C # application, but when I start the application does not happen anything. .. When I try to kill with a command prompt, I get the message: "Access denied" I tried to run as my app administrator and the process was killed. How can I not always use "Run as administrator"? Code: System.Diagnostics.Process process = new System.Diagnostics.Process (); System.Diagnostics.ProcessStartInfo startInfo = New system. Diagnostics. Process STARTINFO (); StartInfo.WindowStyle = System.Diagnostics.ProcessWindowStyle.Hidden; StartInfo.FileName = "cmd.exe"; StartInfo.Arguments = "/ C Tasky / F / IM APP.exe"; Process.start.info = startInfo; Process.start (); try it System.Diagnostics.Process Process = new system Diagnostics Process (); System.Diagnostics.ProcessStartInfo startInfo = New system. Diagnostics. Process STARTINFO (); StartInfo.WindowStyle = System.Diagnostics.ProcessWindowS...
Read more