summaryrefslogtreecommitdiffstats
path: root/gearman/controllerWorker/ControllerWorker/BootWorker.java
diff options
context:
space:
mode:
authorBjörn Geiger2011-08-24 13:56:27 +0200
committerBjörn Geiger2011-08-24 13:56:27 +0200
commit88c3105d9bee90653a1327062183a0726377e9ad (patch)
tree70032ee8e0e9ca33ec3e382de20c580e3424dc3e /gearman/controllerWorker/ControllerWorker/BootWorker.java
parentminor (diff)
downloadpoolctrl-88c3105d9bee90653a1327062183a0726377e9ad.tar.gz
poolctrl-88c3105d9bee90653a1327062183a0726377e9ad.tar.xz
poolctrl-88c3105d9bee90653a1327062183a0726377e9ad.zip
verschiedene Korrekturen
Diffstat (limited to 'gearman/controllerWorker/ControllerWorker/BootWorker.java')
-rw-r--r--gearman/controllerWorker/ControllerWorker/BootWorker.java12
1 files changed, 7 insertions, 5 deletions
diff --git a/gearman/controllerWorker/ControllerWorker/BootWorker.java b/gearman/controllerWorker/ControllerWorker/BootWorker.java
index 22d1e91..5256730 100644
--- a/gearman/controllerWorker/ControllerWorker/BootWorker.java
+++ b/gearman/controllerWorker/ControllerWorker/BootWorker.java
@@ -25,8 +25,10 @@ public class BootWorker extends AbstractGearmanFunction {
JSONObject jsonObject = (JSONObject) JSONValue.parse(data);
String event = jsonObject.get("eventName").toString();
String eventOS = jsonObject.get("eventOS").toString();
- String host = jsonObject.get("host").toString();
- int port = Integer.parseInt(jsonObject.get("port").toString());
+ String gearmanServerHost = jsonObject.get("gearmanServerHost")
+ .toString();
+ int gearmanServerPort = Integer.parseInt(jsonObject.get(
+ "gearmanServerPort").toString());
int updateRate = Integer.parseInt(jsonObject.get("updateRate")
.toString());
long waitTime = Long.parseLong(jsonObject.get("waitTime").toString());
@@ -54,11 +56,11 @@ public class BootWorker extends AbstractGearmanFunction {
psBlacklist.add(blackEntry.toString());
}
- Boot boot = new Boot(host, port, clients, updateRate, waitTime,
- eventOS, psWhitelist, psBlacklist);
+ Boot boot = new Boot(event, clients, eventOS, updateRate, waitTime,
+ psWhitelist, psBlacklist, gearmanServerHost, gearmanServerPort);
StatusWorker.BOOTTHREADS.put(event, boot);
boot.start();
- System.out.println("Booting started");
+ System.out.println("Booting of " + event + " started");
String res = "Booting started";
byte[] warnings = new byte[0];