Spring/spring-integration-flow
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

added unsubscribe to flow handler

Browse Source
This commit is contained in:
David Turanski
2012-02-22 15:02:18 -05:00
parent 06ef00c709
commit a513a2b389
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/org/springframework/integration/flow/handler/FlowMessageHandler.java
View File

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