|
43
|
1 package christie.topology.manager;
|
|
|
2
|
|
|
3 import christie.annotation.Peek;
|
|
|
4 import christie.annotation.Take;
|
|
|
5 import christie.codegear.CodeGear;
|
|
|
6 import christie.codegear.CodeGearManager;
|
|
|
7
|
|
|
8
|
|
|
9 public class TopologyFinish extends CodeGear {
|
|
64
|
10 @Take
|
|
|
11 String finish;
|
|
|
12
|
|
43
|
13 @Peek
|
|
60
|
14 TopologyManagerConfig topologyManagerConfig;
|
|
43
|
15
|
|
|
16 @Take
|
|
|
17 Long startTime;
|
|
|
18
|
|
|
19 @Override
|
|
|
20 protected void run(CodeGearManager cgm) {
|
|
127
|
21 if (topologyManagerConfig.showTime) {
|
|
|
22 System.out.println("TopologymanagerTime = " + (System.currentTimeMillis() - startTime));
|
|
|
23 }
|
|
43
|
24
|
|
127
|
25
|
|
|
26 for(String dgm : cgm.getDGMList().keySet()){
|
|
|
27 getDGM(dgm).put("_CLOSEMESSEAGE", "_CLOSEMESSEAGE");
|
|
|
28 getDGM(dgm).shutdown();
|
|
43
|
29 }
|
|
127
|
30
|
|
|
31 getLocalDGM().finish();
|
|
|
32
|
|
43
|
33 }
|
|
|
34
|
|
|
35 }
|
