svn commit: r585120 - /webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/startup/quartz/SimpleQuartz.java

[ruwan]

Author: ruwan
Date: Tue Oct 16 04:22:57 2007
New Revision: 585120

URL: http://svn.apache.org/viewvc?rev=585120&view=rev
Log:
Fixing the task count issue (SYNAPSE-149)

Modified:
    
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/startup/quartz/SimpleQuartz.java

Modified: 
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/startup/quartz/SimpleQuartz.java
URL: 
http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/startup/quartz/SimpleQuartz.java?rev=585120&r1=585119&r2=585120&view=diff
==============================================================================
--- 
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/startup/quartz/SimpleQuartz.java
 (original)
+++ 
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/startup/quartz/SimpleQuartz.java
 Tue Oct 16 04:22:57 2007
@@ -22,6 +22,7 @@
 import java.util.HashSet;
 import java.util.Random;
 import java.util.Set;
+import java.util.Date;
 
 import javax.xml.namespace.QName;
 
@@ -30,6 +31,7 @@
 import org.apache.commons.logging.LogFactory;
 import org.apache.synapse.core.SynapseEnvironment;
 import org.apache.synapse.SynapseException;
+import org.apache.synapse.SynapseConstants;
 import org.apache.synapse.startup.AbstractStartup;
 import org.quartz.CronTrigger;
 import org.quartz.JobDataMap;
@@ -86,7 +88,11 @@
             sch = DirectSchedulerFactory.getInstance().getScheduler();
             Trigger trigger = null;
             if (cron == null) {
-                trigger = TriggerUtils.makeImmediateTrigger(repeatCount, 
repeatInterval);
+                if (repeatCount >= 0) {
+                    trigger = TriggerUtils.makeImmediateTrigger(repeatCount - 
1, repeatInterval);
+                } else {
+                    trigger = TriggerUtils.makeImmediateTrigger(-1, 
repeatInterval);
+                }
             } else {
                 CronTrigger cronTrig = new CronTrigger();
                 cronTrig.setCronExpression(cron);



---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]