summaryrefslogtreecommitdiffstats
path: root/gearman/controllerWorker/ControllerWorker/StatusWorker.java
diff options
context:
space:
mode:
Diffstat (limited to 'gearman/controllerWorker/ControllerWorker/StatusWorker.java')
-rw-r--r--gearman/controllerWorker/ControllerWorker/StatusWorker.java24
1 files changed, 10 insertions, 14 deletions
diff --git a/gearman/controllerWorker/ControllerWorker/StatusWorker.java b/gearman/controllerWorker/ControllerWorker/StatusWorker.java
index 880b6aa..1698129 100644
--- a/gearman/controllerWorker/ControllerWorker/StatusWorker.java
+++ b/gearman/controllerWorker/ControllerWorker/StatusWorker.java
@@ -52,10 +52,9 @@ public class StatusWorker extends AbstractGearmanFunction {
+ " has not been finished, due to errors!");
LinkedHashMap<String, String> clientErrors = new LinkedHashMap<String, String>();
for (Client client : clients) {
- String clientID = Integer.toString(client.getId());
- String errorText = client.getError();
- if (!errorText.isEmpty()) {
- clientErrors.put(clientID, errorText);
+ if (!client.getError().isEmpty()) {
+ clientErrors.put(Integer.toString(client
+ .getId()), client.getError());
}
}
content.put("clients errors", clientErrors);
@@ -68,9 +67,8 @@ public class StatusWorker extends AbstractGearmanFunction {
+ " has not yet been finished!");
LinkedHashMap<String, String> clientStatus = new LinkedHashMap<String, String>();
for (Client client : clients) {
- String clientID = Integer.toString(client.getId());
- String stateText = client.getStateText();
- clientStatus.put(clientID, stateText);
+ clientStatus.put(Integer.toString(client.getId()),
+ client.getStateText());
}
content.put("clients states", clientStatus);
res.put(event, content);
@@ -101,10 +99,9 @@ public class StatusWorker extends AbstractGearmanFunction {
+ " has not been finished, due to errors!");
LinkedHashMap<String, String> clientErrors = new LinkedHashMap<String, String>();
for (Client client : clients) {
- String clientID = Integer.toString(client.getId());
- String errorText = client.getError();
- if (!errorText.isEmpty()) {
- clientErrors.put(clientID, errorText);
+ if (!client.getError().isEmpty()) {
+ clientErrors.put(Integer.toString(client
+ .getId()), client.getError());
}
}
content.put("clients errors", clientErrors);
@@ -117,9 +114,8 @@ public class StatusWorker extends AbstractGearmanFunction {
+ " has not yet been finished!");
LinkedHashMap<String, String> clientStatus = new LinkedHashMap<String, String>();
for (Client client : clients) {
- String clientID = Integer.toString(client.getId());
- String statusText = client.getStateText();
- clientStatus.put(clientID, statusText);
+ clientStatus.put(Integer.toString(client.getId()),
+ client.getStateText());
}
content.put("clients states", clientStatus);
res.put(event, content);