ode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From boisv...@apache.org
Subject svn commit: r557449 - /incubator/ode/trunk/bpel-runtime/src/main/java/org/apache/ode/bpel/runtime/INVOKE.java
Date Thu, 19 Jul 2007 01:56:45 GMT
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);
                     }
                 });
             }



Mime
View raw message