Changeset 92 for branches/supervisor/src/test/java/omq

Timestamp:

10/01/13 12:02:41 (11 years ago)

Author:

stoda

Message:

TODO: delete in supervisor
check the code

Location:

branches/supervisor/src/test/java/omq/test

Files:

• lock/SleepTest.java (modified) (1 diff)
• supervisor (added)
• supervisor/Sleep.java (added)
• supervisor/SleepImpl.java (added)
• supervisor/SleepTest.java (added)

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

@@ -20 +20 @@
                 env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
                 env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
-                env.setProperty(ParameterQueue.NUM_THREADS, "2");
+                env.setProperty(ParameterQueue.NUM_THREADS, "1");
 
-                SleepImpl sleep = new SleepImpl();
+                for (int i = 0; i < 4; i++) {
+                        Broker broker = new Broker(env);
+                        broker.bind("sleep", new SleepImpl());
+                }
 
-                Broker broker = new Broker(env);
-                broker.bind("sleep", sleep);
         }