Changeset 107 for branches/supervisor/src/test/java

Timestamp:

10/19/13 13:20:44 (12 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

Location:

branches/supervisor/src/test/java

Files:

• omq/test/supervisor/SleepTest.java (modified) (2 diffs)
• test (added)
• test/multi (added)
• test/multi/Beer.java (added)
• test/multi/BeerImpl.java (added)
• test/multi/BeerTest.java (added)
• test/multi/ClientBeer.java (added)
• test/multiBroker (added)
• test/multiBroker/MultiBrokerTest.java (added)
• test/queues (added)
• test/queues/Beer.java (added)
• test/queues/BeerImpl.java (added)
• test/queues/BeerTest.java (added)

branches/supervisor/src/test/java/omq/test/supervisor/SleepTest.java

@@ -25 +25 @@
                 env1.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
                 env1.setProperty(ParameterQueue.RABBIT_PORT, "5672");
-                env1.setProperty(ParameterQueue.MIN_POOL_THREADS, "4");
-                env1.setProperty(ParameterQueue.MAX_POOL_THREADS, "4");
+                env1.setProperty(ParameterQueue.MIN_POOL_THREADS, "1");
+                env1.setProperty(ParameterQueue.MAX_POOL_THREADS, "1");
 
                 Broker broker = new Broker(env1);
@@ -37 +37 @@
                 env2.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
                 env2.setProperty(ParameterQueue.RABBIT_PORT, "5672");
-                env2.setProperty(ParameterQueue.MIN_POOL_THREADS, "4");
-                env2.setProperty(ParameterQueue.MAX_POOL_THREADS, "4");
+                env2.setProperty(ParameterQueue.MIN_POOL_THREADS, "1");
+                env2.setProperty(ParameterQueue.MAX_POOL_THREADS, "1");
 
                 Broker broker2 = new Broker(env2);