summaryrefslogtreecommitdiffstats
path: root/gearman
diff options
context:
space:
mode:
authorBjörn Geiger2011-08-19 10:56:41 +0200
committerBjörn Geiger2011-08-19 10:56:41 +0200
commit330ab830fd8915743348560fe6b2094206dd907d (patch)
tree61f711390b65c2d0a58be81024fca4cccdd76313 /gearman
parentverschiedene Datenbankänderungen (diff)
downloadpoolctrl-330ab830fd8915743348560fe6b2094206dd907d.tar.gz
poolctrl-330ab830fd8915743348560fe6b2094206dd907d.tar.xz
poolctrl-330ab830fd8915743348560fe6b2094206dd907d.zip
verschiedene Gearman Einstellungen in die application.ini verschoben
Diffstat (limited to 'gearman')
-rw-r--r--gearman/controllerWorker/ControllerWorker/BootWorker.java5
-rw-r--r--gearman/controllerWorker/ControllerWorker/ShutdownWorker.java4
2 files changed, 6 insertions, 3 deletions
diff --git a/gearman/controllerWorker/ControllerWorker/BootWorker.java b/gearman/controllerWorker/ControllerWorker/BootWorker.java
index 9049971..e14e380 100644
--- a/gearman/controllerWorker/ControllerWorker/BootWorker.java
+++ b/gearman/controllerWorker/ControllerWorker/BootWorker.java
@@ -25,6 +25,8 @@ public class BootWorker extends AbstractGearmanFunction {
JSONObject jsonObject = (JSONObject) JSONValue.parse(data);
String event = jsonObject.get("eventName").toString();
String eventOS = jsonObject.get("eventOS").toString();
+ String host = jsonObject.get("host").toString();
+ int port = Integer.parseInt(jsonObject.get("port").toString());
int updateRate = Integer.parseInt(jsonObject.get("updateRate")
.toString());
long waitTime = Long.parseLong(jsonObject.get("waitTime").toString());
@@ -39,8 +41,7 @@ public class BootWorker extends AbstractGearmanFunction {
clients.add(clientMap);
}
- Boot boot = new Boot("127.0.0.1", 4730, clients, updateRate, waitTime,
- eventOS);
+ Boot boot = new Boot(host, port, clients, updateRate, waitTime, eventOS);
StatusWorker.BOOTTHREADS.put(event, boot);
boot.start();
System.out.println("Booting started");
diff --git a/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java b/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java
index d2bfbc3..73c659a 100644
--- a/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java
+++ b/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java
@@ -24,6 +24,8 @@ public class ShutdownWorker extends AbstractGearmanFunction {
Vector<HashMap<String, String>> clients = new Vector<HashMap<String, String>>();
JSONObject jsonObject = (JSONObject) JSONValue.parse(data);
String event = jsonObject.get("eventName").toString();
+ String host = jsonObject.get("host").toString();
+ int port = Integer.parseInt(jsonObject.get("port").toString());
int updateRate = Integer.parseInt(jsonObject.get("updateRate")
.toString());
long waitTime = Long.parseLong(jsonObject.get("waitTime").toString());
@@ -38,7 +40,7 @@ public class ShutdownWorker extends AbstractGearmanFunction {
clients.add(clientMap);
}
- Shutdown shutdown = new Shutdown("127.0.0.1", 4730, clients,
+ Shutdown shutdown = new Shutdown(host, port, clients,
updateRate, waitTime);
StatusWorker.SHUTDOWNTHREADS.put(event, shutdown);
shutdown.start();