From 07022dcbd91ea63f71a13f63f323e5b425de577d Mon Sep 17 00:00:00 2001 From: Björn Geiger Date: Mon, 24 Oct 2011 09:36:35 +0200 Subject: Worker.java --- .../controllerWorker/ControllerWorker/Worker.java | 37 ++++++++++++++++++++++ 1 file changed, 37 insertions(+) create mode 100644 gearman/controllerWorker/ControllerWorker/Worker.java (limited to 'gearman') diff --git a/gearman/controllerWorker/ControllerWorker/Worker.java b/gearman/controllerWorker/ControllerWorker/Worker.java new file mode 100644 index 0000000..3501179 --- /dev/null +++ b/gearman/controllerWorker/ControllerWorker/Worker.java @@ -0,0 +1,37 @@ +package ControllerWorker; + +import org.gearman.common.GearmanJobServerConnection; +import org.gearman.common.GearmanNIOJobServerConnection; +import org.gearman.worker.GearmanWorker; +import org.gearman.worker.GearmanWorkerImpl; + +public class Worker extends Thread { + private GearmanWorker worker; + + public Worker() { + final GearmanJobServerConnection connection = new GearmanNIOJobServerConnection( + "127.0.0.1", 4730); + worker = new GearmanWorkerImpl(); + worker.registerFunction(SomePingWorker.class); + worker.registerFunction(BootWorker.class); + worker.registerFunction(ShutdownWorker.class); + worker.registerFunction(StatusWorker.class); + worker.addServer(connection); + } + + public void run() { + work(); + } + + private void work() { + worker.work(); + } + + public boolean isRunning() { + if (worker != null) { + return worker.isRunning(); + } else { + return false; + } + } +} -- cgit v1.2.3-55-g7522