Author: seanahn
Date: Mon Apr 20 18:34:19 2009
New Revision: 766790
URL: http://svn.apache.org/viewvc?rev=766790&view=rev
Log:
changed poll interval configurable, org.apache.ode.polledRunnable.pollInterval
in msecs
Modified:
ode/branches/APACHE_ODE_1.X/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/SimpleScheduler.java
Modified:
ode/branches/APACHE_ODE_1.X/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/SimpleScheduler.java
URL:
http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/SimpleScheduler.java?rev=766790&r1=766789&r2=766790&view=diff
==============================================================================
---
ode/branches/APACHE_ODE_1.X/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/SimpleScheduler.java
(original)
+++
ode/branches/APACHE_ODE_1.X/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/SimpleScheduler.java
Mon Apr 20 18:34:19 2009
@@ -115,6 +115,8 @@
private Random _random = new Random();
+ private long _pollIntervalForPolledRunnable =
Long.getLong("org.apache.ode.polledRunnable.pollInterval", 10 * 60 * 1000);
+
public SimpleScheduler(String nodeId, DatabaseDelegate del, Properties
conf) {
_nodeId = nodeId;
_db = del;
@@ -125,6 +127,10 @@
_tps = getIntProperty(conf, "ode.scheduler.transactionsPerSecond",
_tps);
_todo = new SchedulerThread(this);
}
+
+ public void setPollIntervalForPolledRunnable(long
pollIntervalForPolledRunnable) {
+ _pollIntervalForPolledRunnable = pollIntervalForPolledRunnable;
+ }
private int getIntProperty(Properties props, String propName, int
defaultValue) {
String s = props.getProperty(propName);
@@ -474,7 +480,11 @@
_polledRunnableProcessor.onScheduledJob(jobInfo);
if(
!"COMPLETED".equals(String.valueOf(jobInfo.jobDetail.get("runnable_status"))) )
{
// the runnable is still in progress,
schedule checker to 10 mins later
- job.schedDate = System.currentTimeMillis()
+ 10 * 60 * 1000;
+ if( _pollIntervalForPolledRunnable < 0 ) {
+ if(__log.isWarnEnabled())
__log.warn("The poll interval for polled runnables is negative; setting it to
1000ms");
+ _pollIntervalForPolledRunnable = 1000;
+ }
+ job.schedDate = System.currentTimeMillis()
+ _pollIntervalForPolledRunnable;
_db.insertJob(job, _nodeId, false);
}
} catch (JobProcessorException jpe) {
