summaryrefslogtreecommitdiffstats
path: root/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java
diff options
context:
space:
mode:
Diffstat (limited to 'gearman/controllerWorker/ControllerWorker/ShutdownWorker.java')
-rw-r--r--gearman/controllerWorker/ControllerWorker/ShutdownWorker.java6
1 files changed, 5 insertions, 1 deletions
diff --git a/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java b/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java
index d3d9ae7..62ffee0 100644
--- a/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java
+++ b/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java
@@ -11,7 +11,10 @@ import org.json.simple.JSONArray;
import org.json.simple.JSONObject;
import org.json.simple.JSONValue;
+import org.apache.log4j.Logger;
+
public class ShutdownWorker extends AbstractGearmanFunction {
+ static final Logger logger = Logger.getLogger(ShutdownWorker.class);
@Override
public String getName() {
return "shutdown";
@@ -19,6 +22,7 @@ public class ShutdownWorker extends AbstractGearmanFunction {
@Override
public GearmanJobResult executeFunction() {
+
String data = ByteUtils.fromUTF8Bytes((byte[]) this.data);
Vector<Client> clients = new Vector<Client>();
JSONObject jsonObject = (JSONObject) JSONValue.parse(data);
@@ -55,7 +59,7 @@ public class ShutdownWorker extends AbstractGearmanFunction {
psWhitelist, psBlacklist, gearmanServerHost, gearmanServerPort);
StatusWorker.SHUTDOWNTHREADS.put(event, shutdown);
shutdown.start();
- System.out.println("Shutdown of " + event + " started");
+ logger.info("Shutdown of " + event + " started");
String res = "Shutdown started";
byte[] warnings = new byte[0];