Mercurial > hg > Database > Christie
comparison src/main/java/christie/topology/node/Start.java @ 68:37601b98f0da
update TopologyNode
author | akahori |
---|---|
date | Sat, 01 Sep 2018 08:10:15 +0900 |
parents | 20d4c0cce914 |
children | 36c5c050394d |
comparison
equal
deleted
inserted
replaced
67:d74a64a3940a | 68:37601b98f0da |
---|---|
3 import christie.annotation.Peek; | 3 import christie.annotation.Peek; |
4 import christie.annotation.PeekFrom; | 4 import christie.annotation.PeekFrom; |
5 import christie.annotation.Take; | 5 import christie.annotation.Take; |
6 import christie.codegear.CodeGear; | 6 import christie.codegear.CodeGear; |
7 import christie.codegear.CodeGearManager; | 7 import christie.codegear.CodeGearManager; |
8 import christie.test.topology.localTestTopology.LTRemoteIncrement; | |
8 import org.apache.log4j.Logger; | 9 import org.apache.log4j.Logger; |
9 | 10 |
10 public class Start extends CodeGear { | 11 public class Start extends CodeGear { |
11 | 12 |
12 @PeekFrom("manager") | 13 @Peek |
13 boolean start; | 14 String start; |
14 | 15 |
15 private Logger logger = Logger.getLogger(Start.class); | 16 private Logger logger = Logger.getLogger(Start.class); |
16 | 17 |
17 @Take | 18 //@Take |
18 CodeGear startCS; | 19 CodeGear startCG; |
19 | 20 |
20 | 21 |
21 public Start() { | 22 public Start() { |
23 } | |
24 | |
25 public Start(CodeGear startCG) { | |
26 this.startCG = startCG; | |
22 } | 27 } |
23 | 28 |
24 @Override | 29 @Override |
25 protected void run(CodeGearManager cgm) { | 30 protected void run(CodeGearManager cgm) { |
26 logger.info("Configuration finished."); | 31 logger.info("Configuration finished."); |
27 | 32 |
28 if (startCS == null) return; | 33 if (startCG == null) return; |
29 cgm.setup(startCS); | 34 cgm.setup(startCG); |
30 | 35 |
31 } | 36 } |
32 | 37 |
33 } | 38 } |