view src/main/java/alice/topology/fix/ReceiveDisconnectMessage.java @ 474:6a71732cd3ee dispose

add topology fix package
author sugi
date Sun, 30 Nov 2014 00:01:35 +0900
parents
children cf345b10a21a
line wrap: on
line source

package alice.topology.fix;

import alice.codesegment.CodeSegment;
import alice.datasegment.CommandType;
import alice.datasegment.Receiver;

public class ReceiveDisconnectMessage extends CodeSegment {
    private Receiver info = ids.create(CommandType.PEEK);

    public ReceiveDisconnectMessage() {
        info.setKey("_DISCONNECT");
    }

    @Override
    public void run() {
        new FixTopology();
        new ReceiveDisconnectMessage();
    }
}