servicemix-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jans...@apache.org
Subject svn commit: r1227219 - /servicemix/components/trunk/engines/servicemix-eip/src/main/java/org/apache/servicemix/eip/patterns/AsyncBridge.java
Date Wed, 04 Jan 2012 16:45:10 GMT
Author: janstey
Date: Wed Jan  4 16:45:09 2012
New Revision: 1227219

URL: http://svn.apache.org/viewvc?rev=1227219&view=rev
Log:
SM-2141 - Fix leak in servicemix-eip when handling late responses

Modified:
    servicemix/components/trunk/engines/servicemix-eip/src/main/java/org/apache/servicemix/eip/patterns/AsyncBridge.java

Modified: servicemix/components/trunk/engines/servicemix-eip/src/main/java/org/apache/servicemix/eip/patterns/AsyncBridge.java
URL: http://svn.apache.org/viewvc/servicemix/components/trunk/engines/servicemix-eip/src/main/java/org/apache/servicemix/eip/patterns/AsyncBridge.java?rev=1227219&r1=1227218&r2=1227219&view=diff
==============================================================================
--- servicemix/components/trunk/engines/servicemix-eip/src/main/java/org/apache/servicemix/eip/patterns/AsyncBridge.java
(original)
+++ servicemix/components/trunk/engines/servicemix-eip/src/main/java/org/apache/servicemix/eip/patterns/AsyncBridge.java
Wed Jan  4 16:45:09 2012
@@ -267,11 +267,13 @@ public class AsyncBridge extends EIPEndp
                     throw new IllegalArgumentException("Could not retrieve correlation id
for incoming exchange");
                 }
                 t0 = (MessageExchange) store.load(correlationId + ".t0");
-                store.store(correlationId + ".t2", t2);
                 // The request is found and has not timed out
                 if (t0 != null) {
+                    store.store(correlationId + ".t2", t2);
                     MessageUtil.transferInToOut(t2, t0);
                     send(t0);
+                } else {
+                    done(t2);
                 }
             } else {
                 throw new IllegalStateException();



Mime
View raw message