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() {
		System.out.println("ReceiveReconnectData");
		HostMessage host = hostData.asClass(HostMessage.class);
		DataSegment.remove(host.connectionName);
		DataSegment.connect(host.connectionName, host.reverseName, host.name, host.port);
		ods.put(host.connectionName, "reverseKey", host.reverseName);
		new ReceiveReconnectData();
	}
	

}