|
69
|
1 package christie.test.topology.localTestTopology;
|
|
|
2
|
|
|
3 import christie.annotation.Peek;
|
|
|
4 import christie.annotation.Take;
|
|
|
5 import christie.codegear.CodeGear;
|
|
|
6 import christie.codegear.CodeGearManager;
|
|
|
7
|
|
|
8 public class StartLTCodeGear extends CodeGear{
|
|
|
9
|
|
|
10 @Take
|
|
|
11 boolean running;
|
|
|
12
|
|
|
13 @Override
|
|
|
14 protected void run(CodeGearManager cgm){
|
|
|
15 if(running) cgm.getDGM("node1").put("num", 0);
|
|
|
16 else {
|
|
|
17 cgm.setup(new StartLTCodeGear());
|
|
|
18 getLocalDGM().put("running", running);
|
|
|
19 }
|
|
|
20 }
|
|
|
21 }
|
