svn commit: r511354 - /incubator/ode/trunk/jbi/src/main/java/org/apache/ode/jbi/OdeService.java

[mriou]

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();