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

[janstey]

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