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

Timestamp:

10/02/13 17:31:26 (11 years ago)

Author:

stoda

Message:

ObjectMQ without RemoteWrapper? - one consumer per thread -

Location:

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

Files:

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

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

@@ -16 +16 @@
                 try {
                         System.out.println("I'm going to sleep!!!!!!!!" + Thread.currentThread().getId());
-                        Thread.sleep(1000);
+                        Thread.sleep(2000);
                 } catch (InterruptedException e) {
                         e.printStackTrace();

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

@@ -24 +24 @@
                 env1.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
                 env1.setProperty(ParameterQueue.RABBIT_PORT, "5672");
-                env1.setProperty(ParameterQueue.NUM_THREADS, "1");
+                env1.setProperty(ParameterQueue.NUM_THREADS, "4");
 
                 Broker broker = new Broker(env1);