Changeset 106 for branches/supervisor/src/test

Timestamp:

10/18/13 16:09:36 (11 years ago)

Author:

stoda

Message:

abans que la segueixi liant...

File:

• branches/supervisor/src/test/java/omq/test/supervisor/SleepTest.java (modified) (3 diffs)

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

@@ -13 +13 @@
 
 public class SleepTest {
+        private static String brokerSet = "broker";
 
         @BeforeClass
@@ -42 +43 @@
 
                 // Set supervisor
-                SupervisorImpl supervisor = new SupervisorImpl(500);
+                SupervisorImpl supervisor = new SupervisorImpl(brokerSet, 500);
                 broker.bind("supervisor", supervisor);
+                Thread t = new Thread(supervisor);
+                t.start();
 
-                broker.setSupervisor("supervisor", "b1");
-                broker2.setSupervisor("supervisor", "b2");
+                broker.setSupervisor("supervisor", brokerSet, "b1");
+                broker2.setSupervisor("supervisor", brokerSet, "b2");
         }
 
@@ -63 +66 @@
 
                 OmqSettings settings = new OmqSettings("sleep", SleepImpl.class.getName(), env, 1, 20, 20);
-                supervisor.spawnObject(settings, 0);
+                supervisor.spawnObject(settings);
 
                 Sleep sleep = broker.lookup("sleep", Sleep.class);