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 {