[riftsaw-commits] riftsaw SVN: r964 - branches/ODE/RiftSaw-ODE-trunk/scheduler-simple/src/test/java/org/apache/ode/scheduler/simple.

[riftsaw-commits at lists.jboss.org]

Author: jeff.yuchang
Date: 2010-09-21 01:17:25 -0400 (Tue, 21 Sep 2010)
New Revision: 964

Modified:
   branches/ODE/RiftSaw-ODE-trunk/scheduler-simple/src/test/java/org/apache/ode/scheduler/simple/SimpleSchedulerTest.java
Log:
* remove the recovery test, as this is now happened in riftsaw-clustering.


Modified: branches/ODE/RiftSaw-ODE-trunk/scheduler-simple/src/test/java/org/apache/ode/scheduler/simple/SimpleSchedulerTest.java
===================================================================
--- branches/ODE/RiftSaw-ODE-trunk/scheduler-simple/src/test/java/org/apache/ode/scheduler/simple/SimpleSchedulerTest.java	2010-09-21 03:11:14 UTC (rev 963)
+++ branches/ODE/RiftSaw-ODE-trunk/scheduler-simple/src/test/java/org/apache/ode/scheduler/simple/SimpleSchedulerTest.java	2010-09-21 05:17:25 UTC (rev 964)
@@ -136,30 +136,6 @@
         assertEquals(1, _jobs.size());
     }
 
-    public void testRecovery() throws Exception {
-        // speed things up a bit to hit the right code paths
-        _scheduler.setNearFutureInterval(2000);
-        _scheduler.setImmediateInterval(1000);
-        _scheduler.setStaleInterval(500);
-
-        _txm.begin();
-        try {
-            _scheduler.schedulePersistedJob(newDetail("immediate"), new Date(System.currentTimeMillis()));
-            _scheduler.schedulePersistedJob(newDetail("near"), new Date(System.currentTimeMillis() + 1100));
-            _scheduler.schedulePersistedJob(newDetail("far"), new Date(System.currentTimeMillis() + 2500));
-        } finally {
-            _txm.commit();
-        }
-
-        _scheduler = newScheduler("n3");
-        _scheduler.setNearFutureInterval(2000);
-        _scheduler.setImmediateInterval(1000);
-        _scheduler.setStaleInterval(1000);
-        _scheduler.start();
-        Thread.sleep(4000);
-        assertEquals(3, _jobs.size());
-    }
-
     public void onScheduledJob(final JobInfo jobInfo) throws JobProcessorException {
         synchronized (_jobs) {
             _jobs.add(jobInfo);