ODE-990: added a message coutner to the task git-svn-id: https://svn.apache.org/repos/asf/ode/trunk@1437341 13f79535-47bb-0310-9956-ffa450edef68
diff --git a/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/JobComparatorByDate.java b/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/JobComparatorByDate.java index 83167f2..ccf32e1 100644 --- a/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/JobComparatorByDate.java +++ b/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/JobComparatorByDate.java
@@ -32,7 +32,7 @@ long diff = o1.schedDate - o2.schedDate; if (diff < 0) return -1; if (diff > 0) return 1; - return 0; + return o1.taskSeqNum < o2.taskSeqNum ? -1 : 1; } }
diff --git a/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/Task.java b/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/Task.java index 217b788..1f391ea 100644 --- a/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/Task.java +++ b/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/Task.java
@@ -19,6 +19,8 @@ package org.apache.ode.scheduler.simple; +import java.util.concurrent.atomic.AtomicLong; + /** * The thing that we schedule. * @@ -28,8 +30,11 @@ class Task { /** Scheduled date/time. */ public long schedDate; + public long taskSeqNum; + private static final AtomicLong counter = new AtomicLong(); Task(long schedDate) { this.schedDate = schedDate; + this.taskSeqNum = counter.incrementAndGet(); } }