svn commit: r1438419 - in /ode/branches/ode-1.3.6.x/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple: JobComparatorByDate.java Task.java

[sathwik]

Author: sathwik
Date: Fri Jan 25 10:22:17 2013
New Revision: 1438419

URL: http://svn.apache.org/viewvc?rev=1438419&view=rev
Log:
ODE-990: added a message coutner to the task

Modified:
    
ode/branches/ode-1.3.6.x/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/JobComparatorByDate.java
    
ode/branches/ode-1.3.6.x/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/Task.java

Modified: 
ode/branches/ode-1.3.6.x/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/JobComparatorByDate.java
URL: 
http://svn.apache.org/viewvc/ode/branches/ode-1.3.6.x/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/JobComparatorByDate.java?rev=1438419&r1=1438418&r2=1438419&view=diff
==============================================================================
--- 
ode/branches/ode-1.3.6.x/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/JobComparatorByDate.java
 (original)
+++ 
ode/branches/ode-1.3.6.x/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/JobComparatorByDate.java
 Fri Jan 25 10:22:17 2013
@@ -32,7 +32,7 @@ class JobComparatorByDate implements Com
         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;
     }
 
 }

Modified: 
ode/branches/ode-1.3.6.x/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/Task.java
URL: 
http://svn.apache.org/viewvc/ode/branches/ode-1.3.6.x/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/Task.java?rev=1438419&r1=1438418&r2=1438419&view=diff
==============================================================================
--- 
ode/branches/ode-1.3.6.x/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/Task.java
 (original)
+++ 
ode/branches/ode-1.3.6.x/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/Task.java
 Fri Jan 25 10:22:17 2013
@@ -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 @@ package org.apache.ode.scheduler.simple;
 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();
     }
 }