You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@oodt.apache.org by ma...@apache.org on 2012/04/29 05:27:02 UTC
svn commit: r1331865 - in /oodt/trunk/workflow/src:
main/java/org/apache/oodt/cas/workflow/engine/ThreadPoolWorkflowEngine.java
test/org/apache/oodt/cas/workflow/system/TestXmlRpcWorkflowManager.java
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 {