svn commit: r557449 - /incubator/ode/trunk/bpel-runtime/src/main/java/org/apache/ode/bpel/runtime/INVOKE.java

[boisvert]

Author: boisvert
Date: Wed Jul 18 18:56:44 2007
New Revision: 557449

URL: http://svn.apache.org/viewvc?view=rev&rev=557449
Log:
Cover all bases for partnerMex cleanup

Modified:
    
incubator/ode/trunk/bpel-runtime/src/main/java/org/apache/ode/bpel/runtime/INVOKE.java

Modified: 
incubator/ode/trunk/bpel-runtime/src/main/java/org/apache/ode/bpel/runtime/INVOKE.java
URL: 
http://svn.apache.org/viewvc/incubator/ode/trunk/bpel-runtime/src/main/java/org/apache/ode/bpel/runtime/INVOKE.java?view=diff&rev=557449&r1=557448&r2=557449
==============================================================================
--- 
incubator/ode/trunk/bpel-runtime/src/main/java/org/apache/ode/bpel/runtime/INVOKE.java
 (original)
+++ 
incubator/ode/trunk/bpel-runtime/src/main/java/org/apache/ode/bpel/runtime/INVOKE.java
 Wed Jul 18 18:56:44 2007
@@ -143,8 +143,8 @@
                         // TODO update output variable with data from 
non-initiate
                         // correlation sets
 
-                        getBpelRuntimeContext().releasePartnerMex(mexId);
                         _self.parent.completed(fault, 
CompensationHandler.emptySet());
+                        getBpelRuntimeContext().releasePartnerMex(mexId);
                     }
 
                     public void onFault() {
@@ -154,6 +154,7 @@
                         FaultData fault = createFault(faultName, msg,
                             _oinvoke.getOwner().messageTypes.get(msgType), 
_self.o);
                         _self.parent.completed(fault, 
CompensationHandler.emptySet());
+                        getBpelRuntimeContext().releasePartnerMex(mexId);
                     }
 
                     public void onFailure() {
@@ -162,6 +163,7 @@
                         // and either retry or indicate failure condition.
                         // admin to resume the process.
                         
_self.parent.failure(getBpelRuntimeContext().getPartnerFaultExplanation(mexId), 
null);
+                        getBpelRuntimeContext().releasePartnerMex(mexId);
                     }
                 });
             }