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 a611363..7313687 100644 --- a/src/main/java/org/springframework/integration/flow/handler/FlowMessageHandler.java +++ b/src/main/java/org/springframework/integration/flow/handler/FlowMessageHandler.java @@ -59,7 +59,7 @@ public class FlowMessageHandler extends AbstractReplyProducingMessageHandler { Message message = MessageBuilder .fromMessage(requestMessage) - .copyHeadersIfAbsent(flowConversationIdHeader) + .copyHeaders(flowConversationIdHeader) .build(); Message response = null;