svn commit: r1079564 - /oodt/branches/wengine-branch/wengine/src/main/java/org/apache/oodt/cas/workflow/instance/WorkflowConnectTaskInstance.java

[bfoster]

Author: bfoster
Date: Tue Mar  8 22:04:55 2011
New Revision: 1079564

URL: http://svn.apache.org/viewvc?rev=1079564&view=rev
Log:

- improvements to ConnectWorkflowTaskInstance

--------------------

Modified:
    
oodt/branches/wengine-branch/wengine/src/main/java/org/apache/oodt/cas/workflow/instance/WorkflowConnectTaskInstance.java

Modified: 
oodt/branches/wengine-branch/wengine/src/main/java/org/apache/oodt/cas/workflow/instance/WorkflowConnectTaskInstance.java
URL: 
http://svn.apache.org/viewvc/oodt/branches/wengine-branch/wengine/src/main/java/org/apache/oodt/cas/workflow/instance/WorkflowConnectTaskInstance.java?rev=1079564&r1=1079563&r2=1079564&view=diff
==============================================================================
--- 
oodt/branches/wengine-branch/wengine/src/main/java/org/apache/oodt/cas/workflow/instance/WorkflowConnectTaskInstance.java
 (original)
+++ 
oodt/branches/wengine-branch/wengine/src/main/java/org/apache/oodt/cas/workflow/instance/WorkflowConnectTaskInstance.java
 Tue Mar  8 22:04:55 2011
@@ -130,15 +130,14 @@ public class WorkflowConnectTaskInstance
                                        
spawnedInstanceIds.add(this.weClient.startWorkflow(spawnModelId, 
curWorkflowMet));
                                }catch (Exception e) {
                                        LOG.log(Level.SEVERE, "Failed to start 
workflow ModelId '" + spawnModelId + "' [i = '" + i + "'] : " + e.getMessage(), 
e);
-                                       return new ResultsFailureState("Failed 
to start workflow ModelId '" + spawnModelId + "' [i = '" + i + "'] : " + 
e.getMessage());
-                               }finally {
                                        for (String spawenedInstanceId : 
spawnedInstanceIds) {
                                                try {
                                                        
this.weClient.setWorkflowState(spawenedInstanceId, new StoppedState("Spawing 
workflow failed to spawn sibling workflow [i = '" + i + "']"));
-                                               }catch (Exception e) {
-                                                       LOG.log(Level.SEVERE, 
"Failed to stop workflow InstanceId = '" + spawenedInstanceId + "' : " + 
e.getMessage(), e);
+                                               }catch (Exception e2) {
+                                                       LOG.log(Level.SEVERE, 
"Failed to stop workflow InstanceId = '" + spawenedInstanceId + "' : " + 
e2.getMessage(), e2);
                                                }
                                        }
+                                       return new ResultsFailureState("Failed 
to start workflow ModelId '" + spawnModelId + "' [i = '" + i + "'] : " + 
e.getMessage());
                                }
                        }
                        ctrlMetadata.replaceLocalMetadata(SPAWNED_WORKFLOWS, 
spawnedInstanceIds);