diff --git a/modules/core/src/main/java/org/apache/synapse/message/senders/blocking/BlockingMsgSender.java b/modules/core/src/main/java/org/apache/synapse/message/senders/blocking/BlockingMsgSender.java index 82e5df42d0..8249a9896b 100644 --- a/modules/core/src/main/java/org/apache/synapse/message/senders/blocking/BlockingMsgSender.java +++ b/modules/core/src/main/java/org/apache/synapse/message/senders/blocking/BlockingMsgSender.java @@ -348,6 +348,8 @@ public void send(EndpointDefinition endpointDefinition, MessageContext synapseIn axisInMsgCtx.getProperty(SynapseConstants.NO_KEEPALIVE)); axisOutMsgCtx.setProperty(SynapseConstants.NO_DEFAULT_CONTENT_TYPE, axisInMsgCtx.getProperty(SynapseConstants.NO_DEFAULT_CONTENT_TYPE)); + axisOutMsgCtx.setProperty(SynapseConstants.NO_KEEPALIVE, + axisInMsgCtx.getProperty(SynapseConstants.NO_KEEPALIVE)); // Fill MessageContext BlockingMsgSenderUtils.fillMessageContext(endpointDefinition, axisOutMsgCtx, synapseInMsgCtx); if (JsonUtil.hasAJsonPayload(axisInMsgCtx)) {