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.java17
1 files changed, 15 insertions, 2 deletions
diff --git a/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java b/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java
index 73c659a..5bbc165 100644
--- a/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java
+++ b/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java
@@ -40,8 +40,21 @@ public class ShutdownWorker extends AbstractGearmanFunction {
clients.add(clientMap);
}
- Shutdown shutdown = new Shutdown(host, port, clients,
- updateRate, waitTime);
+ JSONArray whitelist = (JSONArray) jsonObject.get("whitelist");
+ JSONArray blacklist = (JSONArray) jsonObject.get("blacklist");
+ Vector<String> psWhitelist = new Vector<String>();
+ Vector<String> psBlacklist = new Vector<String>();
+
+ for (Object whiteEntry : whitelist) {
+ psWhitelist.add(whiteEntry.toString());
+ }
+
+ for (Object blackEntry : blacklist) {
+ psBlacklist.add(blackEntry.toString());
+ }
+
+ Shutdown shutdown = new Shutdown(host, port, clients, updateRate,
+ waitTime, psWhitelist, psBlacklist);
StatusWorker.SHUTDOWNTHREADS.put(event, shutdown);
shutdown.start();
System.out.println("Shutdown started");