You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ode.apache.org by bo...@apache.org on 2007/07/19 03:56:45 UTC
svn commit: r557449 -
/incubator/ode/trunk/bpel-runtime/src/main/java/org/apache/ode/bpel/runtime/INVOKE.java
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);
}
});
}