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

Changed conversation Id to correspond to handler instance

Browse Source
This commit is contained in:
David Turanski
2011-12-06 19:00:32 -05:00
parent e66c654395
commit 0b0155497c
1 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -86,12 +86,11 @@ public class FlowMessageHandler extends AbstractReplyProducingMessageHandler {
@Override
protected Object handleRequestMessage(Message<?> requestMessage) {
UUID conversationId = requestMessage.getHeaders().getId();
Map<String, Object> flowConversationIdHeader = Collections.singletonMap(
FlowConstants.FLOW_CONVERSATION_ID_HEADER, (Object) conversationId);
String conversationId = this.toString();
Map<String, String> flowConversationIdHeader = Collections.singletonMap(
FlowConstants.FLOW_CONVERSATION_ID_HEADER, this.toString());
Message<?> message = MessageBuilder.fromMessage(requestMessage).copyHeaders(flowConversationIdHeader)
.build();
try {
@@ -123,11 +122,11 @@ public class FlowMessageHandler extends AbstractReplyProducingMessageHandler {
* Internal MessageHandler for the flow response
*/
private static class ResponseMessageHandler implements MessageHandler {
private final UUID conversationId;
private final String conversationId;
private volatile Message<?> response;
public ResponseMessageHandler(UUID conversationId) {
public ResponseMessageHandler(String conversationId) {
this.conversationId = conversationId;
}