diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/handler/AbstractReplyProducingMessageHandler.java b/org.springframework.integration/src/main/java/org/springframework/integration/handler/AbstractReplyProducingMessageHandler.java index a9e4d0d78e..c8506095c5 100644 --- a/org.springframework.integration/src/main/java/org/springframework/integration/handler/AbstractReplyProducingMessageHandler.java +++ b/org.springframework.integration/src/main/java/org/springframework/integration/handler/AbstractReplyProducingMessageHandler.java @@ -93,6 +93,9 @@ public abstract class AbstractReplyProducingMessageHandler extends AbstractMessa throw new MessageHandlingException(message, "handler '" + this + "' requires a reply, but no reply was received"); } + if (logger.isDebugEnabled()) { + logger.debug("handler '" + this + "' produced no reply for request Message: " + message); + } return; } Object targetChannelValue = replyMessageHolder.getTargetChannel(); @@ -113,6 +116,9 @@ public abstract class AbstractReplyProducingMessageHandler extends AbstractMessa protected abstract void handleRequestMessage(Message requestMessage, ReplyMessageHolder replyMessageHolder); protected boolean sendReplyMessage(Message replyMessage, MessageChannel replyChannel) { + if (logger.isDebugEnabled()) { + logger.debug("handler '" + this + "' sending reply Message: " + replyMessage); + } return this.channelTemplate.send(replyMessage, replyChannel); }