svn commit: r540795 - /incubator/ode/trunk/jbi/src/main/java/org/apache/ode/jbi/OdeConsumer.java

[boisvert]

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