Changeset 107 for branches/supervisor/src/main/java/omq/server/InvocationThread.java

Timestamp:

10/19/13 13:20:44 (11 years ago)

Author:

stoda

Message:

Error detected: there should be only one thread listening to the multiexchange queue.
TODO: change this. Make refactor in the invocationthread. Change remotethreadpool to achieve this behavior.
AInvocationThread <- InvocationTHread

<- MultiInvocationTHread

File:

• branches/supervisor/src/main/java/omq/server/InvocationThread.java (modified) (2 diffs)

branches/supervisor/src/main/java/omq/server/InvocationThread.java

@@ -172 +172 @@
                 channel = broker.getNewChannel();
 
-                /*
-                 * Default queue, Round Robin behaviour
-                 */
-
                 // Get info about which exchange and queue will use
                 String exchange = env.getProperty(ParameterQueue.RPC_EXCHANGE, "");
@@ -242 +238 @@
                  */
 
+                // Disable Round Robin behavior 
                 boolean autoAck = false;