summaryrefslogtreecommitdiffstats
path: root/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java
diff options
context:
space:
mode:
Diffstat (limited to 'gearman/controllerWorker/ControllerWorker/ShutdownWorker.java')
-rw-r--r--gearman/controllerWorker/ControllerWorker/ShutdownWorker.java4
1 files changed, 3 insertions, 1 deletions
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();