summaryrefslogtreecommitdiffstats
path: root/gearman/controllerWorker/ControllerWorker/ControllerWorkerMain.java
diff options
context:
space:
mode:
authorBjörn Geiger2011-10-20 16:59:29 +0200
committerBjörn Geiger2011-10-20 16:59:29 +0200
commit54a3c83fa9a5e380804111671b019d6c15df9b04 (patch)
tree5361ef7ed1c4cef0eca2dd2d650666c23a3e7c76 /gearman/controllerWorker/ControllerWorker/ControllerWorkerMain.java
parentjar update (diff)
downloadpoolctrl-54a3c83fa9a5e380804111671b019d6c15df9b04.tar.gz
poolctrl-54a3c83fa9a5e380804111671b019d6c15df9b04.tar.xz
poolctrl-54a3c83fa9a5e380804111671b019d6c15df9b04.zip
Korrektur!
Diffstat (limited to 'gearman/controllerWorker/ControllerWorker/ControllerWorkerMain.java')
-rwxr-xr-xgearman/controllerWorker/ControllerWorker/ControllerWorkerMain.java14
1 files changed, 0 insertions, 14 deletions
diff --git a/gearman/controllerWorker/ControllerWorker/ControllerWorkerMain.java b/gearman/controllerWorker/ControllerWorker/ControllerWorkerMain.java
index 83a4068..44fe78e 100755
--- a/gearman/controllerWorker/ControllerWorker/ControllerWorkerMain.java
+++ b/gearman/controllerWorker/ControllerWorker/ControllerWorkerMain.java
@@ -4,11 +4,6 @@ import java.io.FileInputStream;
import java.util.PropertyResourceBundle;
import java.util.ResourceBundle;
-import org.gearman.common.GearmanJobServerConnection;
-import org.gearman.common.GearmanNIOJobServerConnection;
-import org.gearman.worker.GearmanWorker;
-import org.gearman.worker.GearmanWorkerImpl;
-
import org.apache.log4j.ConsoleAppender;
import org.apache.log4j.FileAppender;
import org.apache.log4j.Logger;
@@ -49,17 +44,8 @@ public class ControllerWorkerMain {
} catch (Exception e) {
logger.error(e.toString());
}
- 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);
PoolctrlRequest poolctrlRequest = new PoolctrlRequest();
poolctrlRequest.start();
- worker.work();
} else {
/**
* keine Übergabeparameter vorhanden