summaryrefslogtreecommitdiffstats
path: root/gearman/controllerWorker/ControllerWorker/StatusWorker.java
diff options
context:
space:
mode:
Diffstat (limited to 'gearman/controllerWorker/ControllerWorker/StatusWorker.java')
-rwxr-xr-xgearman/controllerWorker/ControllerWorker/StatusWorker.java6
1 files changed, 4 insertions, 2 deletions
diff --git a/gearman/controllerWorker/ControllerWorker/StatusWorker.java b/gearman/controllerWorker/ControllerWorker/StatusWorker.java
index 4700dbe..47a4b5c 100755
--- a/gearman/controllerWorker/ControllerWorker/StatusWorker.java
+++ b/gearman/controllerWorker/ControllerWorker/StatusWorker.java
@@ -231,6 +231,7 @@ public class StatusWorker extends AbstractGearmanFunction {
private GearmanJobResult createBootState(JSONObject jsonObject) {
String event = jsonObject.get("eventName").toString();
String eventOS = jsonObject.get("eventOS").toString();
+ Boolean force = Boolean.valueOf(jsonObject.get("force").toString());
JSONArray jsonArray = (JSONArray) jsonObject.get("clients");
Vector<Client> clients = new Vector<Client>();
for (Object clientObj : jsonArray) {
@@ -238,7 +239,7 @@ public class StatusWorker extends AbstractGearmanFunction {
Client client = new Client(clientJsonObj, "boot", event);
clients.add(client);
}
- BootState boot = new BootState(event, clients, eventOS);
+ BootState boot = new BootState(event, force, clients, eventOS);
BOOTSTATES.put(event, boot);
String jsonResult = "{boot state successfully created}";
byte[] warnings = new byte[0];
@@ -253,6 +254,7 @@ public class StatusWorker extends AbstractGearmanFunction {
private GearmanJobResult createShutdownState(JSONObject jsonObject) {
String event = jsonObject.get("eventName").toString();
+ Boolean force = Boolean.valueOf(jsonObject.get("force").toString());
JSONArray jsonArray = (JSONArray) jsonObject.get("clients");
Vector<Client> clients = new Vector<Client>();
for (Object clientObj : jsonArray) {
@@ -260,7 +262,7 @@ public class StatusWorker extends AbstractGearmanFunction {
Client client = new Client(clientJsonObj, "shutdown", event);
clients.add(client);
}
- ShutdownState shutdown = new ShutdownState(event, clients);
+ ShutdownState shutdown = new ShutdownState(event, force, clients);
SHUTDOWNSTATES.put(event, shutdown);
String jsonResult = "{shutdown state successfully created}";
byte[] warnings = new byte[0];