Author: mattmann
Date: Sun Apr 29 03:27:01 2012
New Revision: 1331865
URL: http://svn.apache.org/viewvc?rev=1331865&view=rev
Log:
- OODT-215 and OODT-310 WIP: all tests now pass!
Modified:
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/ThreadPoolWorkflowEngine.java
oodt/trunk/workflow/src/test/org/apache/oodt/cas/workflow/system/TestXmlRpcWorkflowManager.java
Modified:
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/ThreadPoolWorkflowEngine.java
URL:
http://svn.apache.org/viewvc/oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/ThreadPoolWorkflowEngine.java?rev=1331865&r1=1331864&r2=1331865&view=diff
==============================================================================
---
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/ThreadPoolWorkflowEngine.java
(original)
+++
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/ThreadPoolWorkflowEngine.java
Sun Apr 29 03:27:01 2012
@@ -162,6 +162,7 @@ public class ThreadPoolWorkflowEngine im
persistWorkflowInstance(wInst);
SequentialProcessor worker = new
SequentialProcessor(this.lifecycleManager);
+ worker.setWorkflowInstance(wInst);
workerMap.put(wInst.getId(), worker);
wInst.setStatus(QUEUED);
@@ -222,8 +223,7 @@ public class ThreadPoolWorkflowEngine im
*/
@Override
public WorkflowInstanceRepository getInstanceRepository() {
- // TODO Auto-generated method stub
- return null;
+ return this.instRep;
}
/*
Modified:
oodt/trunk/workflow/src/test/org/apache/oodt/cas/workflow/system/TestXmlRpcWorkflowManager.java
URL:
http://svn.apache.org/viewvc/oodt/trunk/workflow/src/test/org/apache/oodt/cas/workflow/system/TestXmlRpcWorkflowManager.java?rev=1331865&r1=1331864&r2=1331865&view=diff
==============================================================================
---
oodt/trunk/workflow/src/test/org/apache/oodt/cas/workflow/system/TestXmlRpcWorkflowManager.java
(original)
+++
oodt/trunk/workflow/src/test/org/apache/oodt/cas/workflow/system/TestXmlRpcWorkflowManager.java
Sun Apr 29 03:27:01 2012
@@ -63,7 +63,7 @@ public class TestXmlRpcWorkflowManager e
}
assertNotNull(workflowInsts);
- assertEquals(1, workflowInsts.size());
+ assertEquals(2, workflowInsts.size());
}
protected void setUp() throws Exception {
