Author: karthick
Date: Mon Dec 22 13:21:50 2008
New Revision: 728781
URL: http://svn.apache.org/viewvc?rev=728781&view=rev
Log:
Fix for ODE-469
Modified:
ode/branches/APACHE_ODE_1.X/scheduler-simple/src/test/java/org/apache/ode/scheduler/simple/SimpleSchedulerTest.java
Modified:
ode/branches/APACHE_ODE_1.X/scheduler-simple/src/test/java/org/apache/ode/scheduler/simple/SimpleSchedulerTest.java
URL:
http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/scheduler-simple/src/test/java/org/apache/ode/scheduler/simple/SimpleSchedulerTest.java?rev=728781&r1=728780&r2=728781&view=diff
==============================================================================
---
ode/branches/APACHE_ODE_1.X/scheduler-simple/src/test/java/org/apache/ode/scheduler/simple/SimpleSchedulerTest.java
(original)
+++
ode/branches/APACHE_ODE_1.X/scheduler-simple/src/test/java/org/apache/ode/scheduler/simple/SimpleSchedulerTest.java
Mon Dec 22 13:21:50 2008
@@ -64,8 +64,9 @@
int jobs = _jobs.size();
jobId = _scheduler.schedulePersistedJob(newDetail("123"), new
Date(System.currentTimeMillis() + 200));
Thread.sleep(100);
- // Make sure we don't schedule until commit.
- assertEquals(jobs, _jobs.size());
+ // we're using transacted jobs which means it will commit at
the end
+ // if the job is scheduled, the following assert is not valid
@seanahn
+ // assertEquals(jobs, _jobs.size());
} finally {
_txm.commit();
}
@@ -84,8 +85,9 @@
try {
_scheduler.schedulePersistedJob(newDetail("123"), new Date());
Thread.sleep(100);
- // Make sure we don't schedule until commit.
- assertEquals(0, _jobs.size());
+ // we're using transacted jobs which means it will commit at the
end
+ // if the job is scheduled, the following assert is not valid
@seanahn
+ // assertEquals(jobs, _jobs.size());
} finally {
_txm.commit();
}