summaryrefslogtreecommitdiffstats
path: root/gearman/controllerWorker/ControllerWorker/PoolctrlRequest.java
diff options
context:
space:
mode:
Diffstat (limited to 'gearman/controllerWorker/ControllerWorker/PoolctrlRequest.java')
-rwxr-xr-xgearman/controllerWorker/ControllerWorker/PoolctrlRequest.java28
1 files changed, 23 insertions, 5 deletions
diff --git a/gearman/controllerWorker/ControllerWorker/PoolctrlRequest.java b/gearman/controllerWorker/ControllerWorker/PoolctrlRequest.java
index 086b88b..373d2e2 100755
--- a/gearman/controllerWorker/ControllerWorker/PoolctrlRequest.java
+++ b/gearman/controllerWorker/ControllerWorker/PoolctrlRequest.java
@@ -1,26 +1,35 @@
package ControllerWorker;
import java.io.BufferedReader;
+import java.io.FileInputStream;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;
+import java.util.PropertyResourceBundle;
import org.apache.log4j.Logger;
public class PoolctrlRequest extends Thread {
- private static final Logger logger = Logger.getLogger(PoolctrlRequest.class);
+ static final Logger logger = Logger.getLogger(PoolctrlRequest.class);
+
private URL runURL;
private URL reportURL;
private final long updatePeriod;
+ private PropertyResourceBundle iniFile;
- public PoolctrlRequest(String runURL, String reportURL, long updatePeriod) {
+ public PoolctrlRequest() {
+ iniFile = getIniFile("../../application/configs/application.ini");
+ updatePeriod = Long.parseLong(iniFile.getString("event.updatePeriod")) * 60L * 1000000000L; // nanoseconds
try {
- this.runURL = new URL(runURL);
- this.reportURL = new URL(reportURL);
+ this.runURL = new URL("http://"
+ + iniFile.getString("poolctrl.host")
+ + iniFile.getString("poolctrl.runevent"));
+ this.reportURL = new URL("http://"
+ + iniFile.getString("poolctrl.host")
+ + iniFile.getString("poolctrl.reportevent"));
} catch (Exception e) {
logger.error(e.toString());
}
- this.updatePeriod = updatePeriod;
}
public void run() {
@@ -80,4 +89,13 @@ public class PoolctrlRequest extends Thread {
logger.error(e.toString());
}
}
+
+ 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