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/05/23 02:02:42 UTC
svn commit: r540795 -
/incubator/ode/trunk/jbi/src/main/java/org/apache/ode/jbi/OdeConsumer.java
Author: boisvert
Date: Tue May 22 17:02:41 2007
New Revision: 540795
URL: http://svn.apache.org/viewvc?view=rev&rev=540795
Log:
Properly handle ExchangeStatus.DONE
Modified:
incubator/ode/trunk/jbi/src/main/java/org/apache/ode/jbi/OdeConsumer.java
Modified: incubator/ode/trunk/jbi/src/main/java/org/apache/ode/jbi/OdeConsumer.java
URL: http://svn.apache.org/viewvc/incubator/ode/trunk/jbi/src/main/java/org/apache/ode/jbi/OdeConsumer.java?view=diff&rev=540795&r1=540794&r2=540795
==============================================================================
--- incubator/ode/trunk/jbi/src/main/java/org/apache/ode/jbi/OdeConsumer.java (original)
+++ incubator/ode/trunk/jbi/src/main/java/org/apache/ode/jbi/OdeConsumer.java Tue May 22 17:02:41 2007
@@ -184,6 +184,8 @@
_ode.getChannel().send(jbiMex);
} else if (jbiMex.getStatus() == ExchangeStatus.ERROR) {
outFailure((InOut) jbiMex);
+ } else if (jbiMex.getStatus() == ExchangeStatus.DONE) {
+ _outstandingExchanges.remove(jbiMex.getExchangeId());
} else {
__log.error("Unexpected status " + jbiMex.getStatus() + " for JBI message exchange: " + jbiMex.getExchangeId());
}