package christie.example.RemoteEditorTest;

import christie.annotation.Take;
import christie.codegear.CodeGear;
import christie.codegear.CodeGearManager;
import christie.topology.Message;


public class CountMessage extends CodeGear {
    @Take
    Message msg;

    @Take
    int msgCount;

    @Override
    protected void run(CodeGearManager cgm) {
        msgCount += 1;
        if (msgCount == 2){
            System.out.println("message comp:" + msgCount );
            cgm.getDGM("node1").put("start", new Message());
            cgm.getDGM("node2").put("start", new Message());
        }else{
            System.out.println("message uncomp:" + msgCount );
            cgm.setup(new CountMessage());
            getLocalDGM().put("msgCount", msgCount);

        }
    }
}