summaryrefslogtreecommitdiffstats
path: root/gearman/controllerWorker/ControllerWorker/ControllerWorkerMain.java
diff options
context:
space:
mode:
Diffstat (limited to 'gearman/controllerWorker/ControllerWorker/ControllerWorkerMain.java')
-rwxr-xr-xgearman/controllerWorker/ControllerWorker/ControllerWorkerMain.java32
1 files changed, 28 insertions, 4 deletions
diff --git a/gearman/controllerWorker/ControllerWorker/ControllerWorkerMain.java b/gearman/controllerWorker/ControllerWorker/ControllerWorkerMain.java
index 1a090b2..d668cd2 100755
--- a/gearman/controllerWorker/ControllerWorker/ControllerWorkerMain.java
+++ b/gearman/controllerWorker/ControllerWorker/ControllerWorkerMain.java
@@ -1,13 +1,22 @@
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);
@@ -18,10 +27,25 @@ public class ControllerWorkerMain {
worker.registerFunction(StatusWorker.class);
worker.addServer(connection);
BasicConfigurator.configure();
+ 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.run();
worker.work();
- RunEvents runEvents;
- runEvents = new RunEvents(
- "http://poolctrl.local/event/run/apikey/apikey1", 300000L);
- runEvents.run();
+ }
+
+ 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