From a513a2b389eeb061ff4d8581fccf861e9e37806d Mon Sep 17 00:00:00 2001
From: David Turanski <dturanski@gmail.com>
Date: Wed, 22 Feb 2012 15:02:18 -0500
Subject: [PATCH] added unsubscribe to flow handler

---
 .../integration/flow/handler/FlowMessageHandler.java          | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/main/java/org/springframework/integration/flow/handler/FlowMessageHandler.java b/src/main/java/org/springframework/integration/flow/handler/FlowMessageHandler.java
index 7cb00a1..8622bb3 100644
--- a/src/main/java/org/springframework/integration/flow/handler/FlowMessageHandler.java
+++ b/src/main/java/org/springframework/integration/flow/handler/FlowMessageHandler.java
@@ -91,7 +91,9 @@ public class FlowMessageHandler extends AbstractReplyProducingMessageHandler {
 
 			ResponseMessageHandler responseMessageHandler = new ResponseMessageHandler(conversationId);
 			flowOutputChannel.subscribe(responseMessageHandler);
-			flowInputChannel.send(message, timeout);
+			flowInputChannel.send(message, timeout);	
+			flowOutputChannel.unsubscribe(responseMessageHandler);
+		 
 			return responseMessageHandler.getResponse();
 
 		}