summaryrefslogtreecommitdiffstats
path: root/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java
diff options
context:
space:
mode:
Diffstat (limited to 'gearman/controllerWorker/ControllerWorker/ShutdownWorker.java')
-rwxr-xr-xgearman/controllerWorker/ControllerWorker/ShutdownWorker.java32
1 files changed, 10 insertions, 22 deletions
diff --git a/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java b/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java
index c6f63b9..46520c5 100755
--- a/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java
+++ b/gearman/controllerWorker/ControllerWorker/ShutdownWorker.java
@@ -1,8 +1,5 @@
package ControllerWorker;
-import java.io.FileInputStream;
-import java.util.PropertyResourceBundle;
-import java.util.ResourceBundle;
import java.util.StringTokenizer;
import java.util.Vector;
@@ -20,8 +17,6 @@ import org.apache.log4j.Logger;
public class ShutdownWorker extends AbstractGearmanFunction {
static final Logger logger = Logger.getLogger(ShutdownWorker.class);
- private ResourceBundle iniFile;
-
@Override
public String getName() {
return "shutdown";
@@ -29,7 +24,6 @@ public class ShutdownWorker extends AbstractGearmanFunction {
@Override
public GearmanJobResult executeFunction() {
- iniFile = getIniFile("../../application/configs/application.ini");
String data = ByteUtils.fromUTF8Bytes((byte[]) this.data);
Vector<Client> clients = new Vector<Client>();
JSONObject jsonObject = (JSONObject) JSONValue.parse(data);
@@ -43,16 +37,19 @@ public class ShutdownWorker extends AbstractGearmanFunction {
clients.add(client);
}
- String gearmanServerHost = iniFile.getString("gearman.server.host");
- int gearmanServerPort = Integer.parseInt(iniFile
- .getString("gearman.server.port"));
- long waitTime = Long.parseLong(iniFile
+ String gearmanServerHost = ControllerWorkerMain.getIniFile().getString(
+ "gearman.server.host");
+ int gearmanServerPort = Integer.parseInt(ControllerWorkerMain
+ .getIniFile().getString("gearman.server.port"));
+ long waitTime = Long.parseLong(ControllerWorkerMain.getIniFile()
.getString("gearman.worker.waitTime"));
- int updateRate = Integer.parseInt(iniFile
+ int updateRate = Integer.parseInt(ControllerWorkerMain.getIniFile()
.getString("gearman.worker.updateRate"));
- String blacklist = iniFile.getString("gearman.worker.ps.blacklist");
+ String blacklist = ControllerWorkerMain.getIniFile().getString(
+ "gearman.worker.ps.blacklist");
StringTokenizer blacklistTokenizer = new StringTokenizer(blacklist, ",");
- String whitelist = iniFile.getString("gearman.worker.ps.whitelist");
+ String whitelist = ControllerWorkerMain.getIniFile().getString(
+ "gearman.worker.ps.whitelist");
StringTokenizer whitelistTokenizer = new StringTokenizer(whitelist, ",");
Vector<String> psWhitelist = new Vector<String>();
Vector<String> psBlacklist = new Vector<String>();
@@ -80,13 +77,4 @@ public class ShutdownWorker extends AbstractGearmanFunction {
res.getBytes(), warnings, exceptions, numerator, denominator);
return gjr;
}
-
- private static PropertyResourceBundle getIniFile(String file) {
- try {
- return new PropertyResourceBundle(new FileInputStream(file));
- } catch (Exception e) {
- logger.error(e.toString());
- return null;
- }
- }
} \ No newline at end of file