Author: gnodet
Date: Wed Feb 11 16:56:10 2009
New Revision: 743389
URL: http://svn.apache.org/viewvc?rev=743389&view=rev
Log:
SMX4NMR-72: The ExchangeCompletedListener should only catch done/error
exchanges when they are delivered, not sent
Modified:
servicemix/smx4/nmr/trunk/jbi/runtime/src/test/java/org/apache/servicemix/jbi/runtime/ExchangeCompletedListener.java
Modified:
servicemix/smx4/nmr/trunk/jbi/runtime/src/test/java/org/apache/servicemix/jbi/runtime/ExchangeCompletedListener.java
URL:
http://svn.apache.org/viewvc/servicemix/smx4/nmr/trunk/jbi/runtime/src/test/java/org/apache/servicemix/jbi/runtime/ExchangeCompletedListener.java?rev=743389&r1=743388&r2=743389&view=diff
==============================================================================
---
servicemix/smx4/nmr/trunk/jbi/runtime/src/test/java/org/apache/servicemix/jbi/runtime/ExchangeCompletedListener.java
(original)
+++
servicemix/smx4/nmr/trunk/jbi/runtime/src/test/java/org/apache/servicemix/jbi/runtime/ExchangeCompletedListener.java
Wed Feb 11 16:56:10 2009
@@ -41,13 +41,21 @@
}
public void exchangeSent(Exchange exchange) {
- synchronized (exchanges) {
- exchanges.put(exchange.getId(), exchange);
- exchanges.notifyAll();
+ if (exchange.getStatus() == Status.Active) {
+ synchronized (exchanges) {
+ exchanges.put(exchange.getId(), exchange);
+ exchanges.notifyAll();
+ }
}
}
public void exchangeDelivered(Exchange exchange) {
+ if (exchange.getStatus() != Status.Active) {
+ synchronized (exchanges) {
+ exchanges.put(exchange.getId(), exchange);
+ exchanges.notifyAll();
+ }
+ }
}
public void assertExchangeCompleted() throws Exception {
