summaryrefslogtreecommitdiffstats
path: root/gearman/controllerWorker/ControllerWorker/ControllerWorkerMain.java
diff options
context:
space:
mode:
authorBjörn Geiger2011-09-12 14:05:59 +0200
committerBjörn Geiger2011-09-12 14:05:59 +0200
commit6550267106ac24a57df2b32e2d1bb50edfa68ec8 (patch)
tree4b24da66fa96df17ca79286c07159bac0f9ebd7c /gearman/controllerWorker/ControllerWorker/ControllerWorkerMain.java
parentminor (diff)
downloadpoolctrl-6550267106ac24a57df2b32e2d1bb50edfa68ec8.tar.gz
poolctrl-6550267106ac24a57df2b32e2d1bb50edfa68ec8.tar.xz
poolctrl-6550267106ac24a57df2b32e2d1bb50edfa68ec8.zip
verschiedene Korrekturen
Diffstat (limited to 'gearman/controllerWorker/ControllerWorker/ControllerWorkerMain.java')
-rwxr-xr-xgearman/controllerWorker/ControllerWorker/ControllerWorkerMain.java29
1 files changed, 1 insertions, 28 deletions
diff --git a/gearman/controllerWorker/ControllerWorker/ControllerWorkerMain.java b/gearman/controllerWorker/ControllerWorker/ControllerWorkerMain.java
index 09eba5b..49ea2ab 100755
--- a/gearman/controllerWorker/ControllerWorker/ControllerWorkerMain.java
+++ b/gearman/controllerWorker/ControllerWorker/ControllerWorkerMain.java
@@ -1,22 +1,13 @@
package ControllerWorker;
-import java.io.FileInputStream;
-import java.util.PropertyResourceBundle;
-import java.util.ResourceBundle;
-
import org.gearman.common.GearmanJobServerConnection;
import org.gearman.common.GearmanNIOJobServerConnection;
import org.gearman.worker.GearmanWorker;
import org.gearman.worker.GearmanWorkerImpl;
import org.apache.log4j.BasicConfigurator;
-import org.apache.log4j.Logger;
public class ControllerWorkerMain {
- private static final Logger logger = Logger
- .getLogger(ControllerWorkerMain.class);
- private static ResourceBundle iniFile;
-
public static void main(String[] args) {
final GearmanJobServerConnection connection = new GearmanNIOJobServerConnection(
"127.0.0.1", 4730);
@@ -27,26 +18,8 @@ public class ControllerWorkerMain {
worker.registerFunction(StatusWorker.class);
worker.addServer(connection);
BasicConfigurator.configure();
- logger.info(System.getProperty("user.dir"));
- iniFile = getIniFile("../../+application/configs/application.ini");
- String runURL = "http://" + iniFile.getString("poolctrl.host")
- + iniFile.getString("poolctrl.runevent");
- String reportURL = "http://" + iniFile.getString("poolctrl.host")
- + iniFile.getString("poolctrl.runevent");
- long updatePeriod = Long.parseLong(iniFile
- .getString("event.updatePeriod")) * 60L * 1000000000L; // nanoseconds
- PoolctrlRequest poolctrlRequest;
- poolctrlRequest = new PoolctrlRequest(runURL, reportURL, updatePeriod);
+ PoolctrlRequest poolctrlRequest = new PoolctrlRequest();
poolctrlRequest.run();
worker.work();
}
-
- 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