summaryrefslogtreecommitdiffstats
path: root/gearman/controllerWorker/ControllerWorker/ShutdownWorker.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/ShutdownWorker.java
parentminor (diff)
downloadpoolctrl-88c3105d9bee90653a1327062183a0726377e9ad.tar.gz
poolctrl-88c3105d9bee90653a1327062183a0726377e9ad.tar.xz
poolctrl-88c3105d9bee90653a1327062183a0726377e9ad.zip
verschiedene Korrekturen
Diffstat (limited to 'gearman/controllerWorker/ControllerWorker/ShutdownWorker.java')
-rw-r--r--gearman/controllerWorker/ControllerWorker/ShutdownWorker.java12
1 files changed, 7 insertions, 5 deletions
diff --git a/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java b/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java
index 5bbc165..2eea21b 100644
--- a/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java
+++ b/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java
@@ -24,8 +24,10 @@ public class ShutdownWorker extends AbstractGearmanFunction {
Vector<HashMap<String, String>> clients = new Vector<HashMap<String, String>>();
JSONObject jsonObject = (JSONObject) JSONValue.parse(data);
String event = jsonObject.get("eventName").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());
@@ -53,11 +55,11 @@ public class ShutdownWorker extends AbstractGearmanFunction {
psBlacklist.add(blackEntry.toString());
}
- Shutdown shutdown = new Shutdown(host, port, clients, updateRate,
- waitTime, psWhitelist, psBlacklist);
+ Shutdown shutdown = new Shutdown(event, clients, updateRate, waitTime,
+ psWhitelist, psBlacklist, gearmanServerHost, gearmanServerPort);
StatusWorker.SHUTDOWNTHREADS.put(event, shutdown);
shutdown.start();
- System.out.println("Shutdown started");
+ System.out.println("Shutdown of " + event + " started");
String res = "Shutdown started";
byte[] warnings = new byte[0];