You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@turbine.apache.org by qu...@apache.org on 2003/05/21 00:00:32 UTC
cvs commit: jakarta-turbine-2/src/java/org/apache/turbine/services/schedule TurbineSchedulerService.java
quintonm 2003/05/20 15:00:32
Modified: src/java/org/apache/turbine/services/schedule
TurbineSchedulerService.java
Log:
Jobs are loaded from persistent storage on when the service is initialized even if the
scheduler is not enabled.
Revision Changes Path
1.15 +11 -15 jakarta-turbine-2/src/java/org/apache/turbine/services/schedule/TurbineSchedulerService.java
Index: TurbineSchedulerService.java
===================================================================
RCS file: /home/cvs/jakarta-turbine-2/src/java/org/apache/turbine/services/schedule/TurbineSchedulerService.java,v
retrieving revision 1.14
retrieving revision 1.15
diff -u -r1.14 -r1.15
--- TurbineSchedulerService.java 9 May 2003 11:09:53 -0000 1.14
+++ TurbineSchedulerService.java 20 May 2003 22:00:32 -0000 1.15
@@ -119,23 +119,19 @@
scheduleQueue = new JobQueue();
mainLoop = new MainLoop();
- if (isEnabled())
- {
-
- // Load all from cold storage.
- List jobs = JobEntryPeer.doSelect(new Criteria());
+ // Load all from cold storage.
+ List jobs = JobEntryPeer.doSelect(new Criteria());
- if (jobs != null && jobs.size() > 0)
+ if (jobs != null && jobs.size() > 0)
+ {
+ Iterator it = jobs.iterator();
+ while (it.hasNext())
{
- Iterator it = jobs.iterator();
- while (it.hasNext())
- {
- ((JobEntry) it.next()).calcRunTime();
- }
- scheduleQueue.batchLoad(jobs);
-
- restart();
+ ((JobEntry) it.next()).calcRunTime();
}
+ scheduleQueue.batchLoad(jobs);
+
+ restart();
}
setInit(true);
---------------------------------------------------------------------
To unsubscribe, e-mail: turbine-dev-unsubscribe@jakarta.apache.org
For additional commands, e-mail: turbine-dev-help@jakarta.apache.org