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