summaryrefslogtreecommitdiffstats
path: root/gearman/controllerWorker/ControllerWorker/BootWorker.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/BootWorker.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/BootWorker.java')
-rw-r--r--gearman/controllerWorker/ControllerWorker/BootWorker.java11
1 files changed, 4 insertions, 7 deletions
diff --git a/gearman/controllerWorker/ControllerWorker/BootWorker.java b/gearman/controllerWorker/ControllerWorker/BootWorker.java
index 5256730..572c5dd 100644
--- a/gearman/controllerWorker/ControllerWorker/BootWorker.java
+++ b/gearman/controllerWorker/ControllerWorker/BootWorker.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 BootWorker 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 eventOS = jsonObject.get("eventOS").toString();
@@ -36,11 +35,9 @@ public class BootWorker 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 booting process of the client has been started.");
+ clients.add(client);
}
JSONArray whitelist = (JSONArray) jsonObject.get("whitelist");