package christie.test.topology.localTestTopology;

import christie.annotation.Peek;
import christie.annotation.Take;
import christie.codegear.CodeGear;
import christie.codegear.CodeGearManager;
import christie.topology.node.TopologyNodeConfig;

import java.util.List;

public class LTRemoteIncrement extends CodeGear {
    @Peek
    TopologyNodeConfig topologyNodeConfig;

    @Take
    int num;

    public LTRemoteIncrement() {

    }

    @Override
    protected void run(CodeGearManager cgm) {
        System.out.println("node: " + " num = " + num);

        if (num == 3) {
            getDGM(topologyNodeConfig.getManagerKey()).put("finish", "");
        } else {
            num++;
            getDGM("right").put("num", num);
            cgm.setup(new LTRemoteIncrement());
        }

    }

}