view src/main/java/christie/topology/manager/keepalive/CreateTask.java @ 121:8949d0ecf1f6

refactor Topology
author akahori
date Tue, 11 Dec 2018 15:46:09 +0900
parents 2c22b23fa725
children
line wrap: on
line source

package christie.topology.manager.keepalive;

import christie.annotation.Peek;
import christie.codegear.CodeGear;
import christie.codegear.CodeGearManager;

import java.util.ArrayList;

public class CreateTask extends CodeGear{
    @Peek
    ArrayList<String> _CLIST;
    @Peek
    ListManager _SCHEDULER;

    public static int INTERVAL = 5;

    public CreateTask(){
    }

    @Override
    protected void run(CodeGearManager cgm){
        int i = INTERVAL;
        for (String manager : _CLIST){
            TaskInfo task = new TaskInfo(TaskType.PING);
            task.setInfo(manager, "_FORM_"+manager, i * 1000);
            _SCHEDULER.addTask(task);
            i +=INTERVAL;
        }
    }
}