package ControllerWorker; import org.gearman.common.GearmanJobServerConnection; import org.gearman.common.GearmanNIOJobServerConnection; import org.gearman.worker.GearmanWorker; import org.gearman.worker.GearmanWorkerImpl; public class ControllerWorkerMain { public static void main(String[] args) { final GearmanJobServerConnection connection = new GearmanNIOJobServerConnection( "127.0.0.1", 4730); GearmanWorker bootWorker = new GearmanWorkerImpl(); bootWorker.registerFunction(BootWorker.class); bootWorker.registerFunction(ShutdownWorker.class); bootWorker.registerFunction(StatusWorker.class); bootWorker.registerFunction(SomePingWorker.class); bootWorker.addServer(connection); bootWorker.work(); } }