summaryrefslogtreecommitdiffstats
path: root/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java
diff options
context:
space:
mode:
authorBjörn Geiger2011-08-31 16:36:30 +0200
committerBjörn Geiger2011-08-31 16:36:30 +0200
commita48ca69d5dc7fd00b43c1678fc1d96c3274ab1f5 (patch)
treeb6767f5c8a596f805c256c5c7950b10edd607b16 /gearman/controllerWorker/ControllerWorker/ShutdownWorker.java
parentkleine änderung (diff)
downloadpoolctrl-a48ca69d5dc7fd00b43c1678fc1d96c3274ab1f5.tar.gz
poolctrl-a48ca69d5dc7fd00b43c1678fc1d96c3274ab1f5.tar.xz
poolctrl-a48ca69d5dc7fd00b43c1678fc1d96c3274ab1f5.zip
Client und State nun als eigenes Objekt, Shutdown.java noch nicht ganz angepasst
Diffstat (limited to 'gearman/controllerWorker/ControllerWorker/ShutdownWorker.java')
-rw-r--r--gearman/controllerWorker/ControllerWorker/ShutdownWorker.java10
1 files changed, 3 insertions, 7 deletions
diff --git a/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java b/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java
index 2eea21b..d3d9ae7 100644
--- a/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java
+++ b/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java
@@ -1,6 +1,5 @@
package ControllerWorker;
-import java.util.HashMap;
import java.util.Vector;
import org.gearman.client.GearmanJobResult;
@@ -21,7 +20,7 @@ public class ShutdownWorker extends AbstractGearmanFunction {
@Override
public GearmanJobResult executeFunction() {
String data = ByteUtils.fromUTF8Bytes((byte[]) this.data);
- Vector<HashMap<String, String>> clients = new Vector<HashMap<String, String>>();
+ Vector<Client> clients = new Vector<Client>();
JSONObject jsonObject = (JSONObject) JSONValue.parse(data);
String event = jsonObject.get("eventName").toString();
String gearmanServerHost = jsonObject.get("gearmanServerHost")
@@ -35,11 +34,8 @@ public class ShutdownWorker extends AbstractGearmanFunction {
for (Object clientObj : jsonArray) {
JSONObject clientJsonObj = (JSONObject) clientObj;
- HashMap<String, String> clientMap = new HashMap<String, String>();
- clientMap.put("id", clientJsonObj.get("id").toString());
- clientMap.put("ip", clientJsonObj.get("ip").toString());
- clientMap.put("mac", clientJsonObj.get("mac").toString());
- clients.add(clientMap);
+ Client client = new Client(clientJsonObj, "The shutdown process of the client has been started.");
+ clients.add(client);
}
JSONArray whitelist = (JSONArray) jsonObject.get("whitelist");