You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ode.apache.org by mr...@apache.org on 2007/02/24 22:26:51 UTC
svn commit: r511354 -
/incubator/ode/trunk/jbi/src/main/java/org/apache/ode/jbi/OdeService.java
Author: mriou
Date: Sat Feb 24 13:26:51 2007
New Revision: 511354
URL: http://svn.apache.org/viewvc?view=rev&rev=511354
Log:
Misplaced the mex.release() for jbi, much better now.
Modified:
incubator/ode/trunk/jbi/src/main/java/org/apache/ode/jbi/OdeService.java
Modified: incubator/ode/trunk/jbi/src/main/java/org/apache/ode/jbi/OdeService.java
URL: http://svn.apache.org/viewvc/incubator/ode/trunk/jbi/src/main/java/org/apache/ode/jbi/OdeService.java?view=diff&rev=511354&r1=511353&r2=511354
==============================================================================
--- incubator/ode/trunk/jbi/src/main/java/org/apache/ode/jbi/OdeService.java (original)
+++ incubator/ode/trunk/jbi/src/main/java/org/apache/ode/jbi/OdeService.java Sat Feb 24 13:26:51 2007
@@ -185,6 +185,7 @@
default:
__log.warn("Received ODE message exchange in unexpected state: " + mex.getStatus());
}
+ mex.release();
}
/**
@@ -246,10 +247,7 @@
if (odeMex.getMessageExchangePattern() != MessageExchangePattern.REQUEST_RESPONSE)
_jbiMexTracker.consume(jbiMex.getExchangeId());
- } finally {
- if (odeMex!= null) odeMex.release();
- else __log.warn("Couldn't release a message exchange, it's null.");
-
+ } finally {
if (success) {
__log.debug("Commiting ODE MEX " + odeMex);
_ode.getTransactionManager().commit();