Mercurial > hg > Database > Christie
view src/main/java/christie/topology/node/TopologyNode.java @ 161:5c5a5da0d13d
add TopoDG
author | akahori |
---|---|
date | Tue, 22 Jan 2019 14:21:15 +0900 |
parents | 42f195de3152 |
children | 6eb548c188e5 |
line wrap: on
line source
package christie.topology.node; import christie.annotation.Peek; import christie.codegear.CodeGear; import christie.codegear.CodeGearManager; import christie.topology.HostMessage; import java.net.InetAddress; import java.net.UnknownHostException; import java.util.ArrayList; public class TopologyNode extends CodeGear{ @Peek TopologyNodeConfig topologyNodeConfig; public TopologyNode() { } @Override protected void run(CodeGearManager cgm) { cgm.createRemoteDGM(topologyNodeConfig.getManagerKey(), topologyNodeConfig.getManagerHostName(), topologyNodeConfig.getManagerPort()); HostMessage hostMessage = new HostMessage(); hostMessage.setLocalHostAndPort(cgm.localPort); hostMessage.setCookie(topologyNodeConfig.cookie); getDGM(topologyNodeConfig.getManagerKey()).put("hostMessage", hostMessage); getLocalDGM().put("reverseCount", 0); cgm.setup(new IncomingConnectionInfo()); cgm.setup(new ConfigurationFinish()); } }