view src/main/java/alice/topology/manager/reconnection/ReceiveReconnectData.java @ 345:8f71c3e6f11d

Change directory structure Maven standard
author sugi
date Wed, 16 Apr 2014 18:26:07 +0900
parents
children
line wrap: on
line source

package alice.topology.manager.reconnection;

import alice.codesegment.CodeSegment;
import alice.datasegment.CommandType;
import alice.datasegment.DataSegment;
import alice.datasegment.Receiver;
import alice.topology.HostMessage;

public class ReceiveReconnectData extends CodeSegment{
	private Receiver hostData = ids.create(CommandType.TAKE);

	public ReceiveReconnectData(){
		hostData.setKey("_RECODATA");
	}
	
	@Override
	public void run() {
		HostMessage host = hostData.asClass(HostMessage.class);
		DataSegment.remove(host.connectionName);
		DataSegment.connect(host.connectionName, host.reverseName, host.name, host.port, host.reconnectFlag);
		ods.put(host.connectionName, "reverseKey", host.reverseName);
		new ReceiveReconnectData();
	}
	

}