Changeset 106 for branches/supervisor/src/test/java
- Timestamp:
- 10/18/13 16:09:36 (11 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
branches/supervisor/src/test/java/omq/test/supervisor/SleepTest.java
r103 r106 13 13 14 14 public class SleepTest { 15 private static String brokerSet = "broker"; 15 16 16 17 @BeforeClass … … 42 43 43 44 // Set supervisor 44 SupervisorImpl supervisor = new SupervisorImpl( 500);45 SupervisorImpl supervisor = new SupervisorImpl(brokerSet, 500); 45 46 broker.bind("supervisor", supervisor); 47 Thread t = new Thread(supervisor); 48 t.start(); 46 49 47 broker.setSupervisor("supervisor", "b1");48 broker2.setSupervisor("supervisor", "b2");50 broker.setSupervisor("supervisor", brokerSet, "b1"); 51 broker2.setSupervisor("supervisor", brokerSet, "b2"); 49 52 } 50 53 … … 63 66 64 67 OmqSettings settings = new OmqSettings("sleep", SleepImpl.class.getName(), env, 1, 20, 20); 65 supervisor.spawnObject(settings , 0);68 supervisor.spawnObject(settings); 66 69 67 70 Sleep sleep = broker.lookup("sleep", Sleep.class);
Note: See TracChangeset
for help on using the changeset viewer.