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 b454cca..d2bfbc3 100644
--- a/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java
+++ b/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java
@@ -26,6 +26,7 @@ public class ShutdownWorker extends AbstractGearmanFunction {
String event = jsonObject.get("eventName").toString();
int updateRate = Integer.parseInt(jsonObject.get("updateRate")
.toString());
+ long waitTime = Long.parseLong(jsonObject.get("waitTime").toString());
JSONArray jsonArray = (JSONArray) jsonObject.get("clients");
for (Object clientObj : jsonArray) {
@@ -37,7 +38,8 @@ public class ShutdownWorker extends AbstractGearmanFunction {
clients.add(clientMap);
}
- Shutdown shutdown = new Shutdown("127.0.0.1", 4730, clients, updateRate);
+ Shutdown shutdown = new Shutdown("127.0.0.1", 4730, clients,
+ updateRate, waitTime);
StatusWorker.SHUTDOWNTHREADS.put(event, shutdown);
shutdown.start();
System.out.println("Shutdown started");