summaryrefslogtreecommitdiffstats
path: root/gearman/controllerWorker/ControllerWorker/BootWorker.java
diff options
context:
space:
mode:
Diffstat (limited to 'gearman/controllerWorker/ControllerWorker/BootWorker.java')
-rwxr-xr-xgearman/controllerWorker/ControllerWorker/BootWorker.java11
1 files changed, 8 insertions, 3 deletions
diff --git a/gearman/controllerWorker/ControllerWorker/BootWorker.java b/gearman/controllerWorker/ControllerWorker/BootWorker.java
index afcf9d6..17b2920 100755
--- a/gearman/controllerWorker/ControllerWorker/BootWorker.java
+++ b/gearman/controllerWorker/ControllerWorker/BootWorker.java
@@ -46,6 +46,10 @@ public class BootWorker extends AbstractGearmanFunction {
if (jsonObject.get("clients") != null) {
jsonClients = (JSONArray) jsonObject.get("clients");
}
+ Boolean force = false;
+ if (jsonObject.get("force") != null) {
+ force = Boolean.valueOf(jsonObject.get("force").toString());
+ }
String res;
if (!event.isEmpty() && !eventOS.isEmpty() && !jsonClients.isEmpty()) {
for (Object clientObj : jsonClients) {
@@ -85,15 +89,16 @@ public class BootWorker extends AbstractGearmanFunction {
psBlacklist.add(blackEntry);
}
- Boot boot = new Boot(event, clients, eventOS, updateRate, waitTime,
- scsavTime, psWhitelist, psBlacklist, gearmanServerHost,
- gearmanServerPort);
+ Boot boot = new Boot(event, force, clients, eventOS, updateRate,
+ waitTime, scsavTime, psWhitelist, psBlacklist,
+ gearmanServerHost, gearmanServerPort);
GearmanJobServerConnection gearmanConnection = new GearmanNIOJobServerConnection(
gearmanServerHost, gearmanServerPort);
GearmanClient gearmanClient = new GearmanClientImpl();
gearmanClient.addJobServer(gearmanConnection);
LinkedHashMap<String, Object> jsonData = new LinkedHashMap<String, Object>();
jsonData.put("eventName", event);
+ jsonData.put("force", force);
jsonData.put("type", "createBootState");
jsonData.put("eventOS", eventOS);
jsonData.put("clients", jsonClients);