From 49c231e547eb050dc3609586ef34f9f17bd12b0e Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Mon, 23 Feb 2015 11:57:56 +0200 Subject: [PATCH] `EnableIntegrationTests`: add more `logger.debug` --- .../configuration/EnableIntegrationTests.java | 16 +++++++++++++++- 1 file changed, 15 insertions(+), 1 deletion(-) diff --git a/spring-integration-core/src/test/java/org/springframework/integration/configuration/EnableIntegrationTests.java b/spring-integration-core/src/test/java/org/springframework/integration/configuration/EnableIntegrationTests.java index e4b6c719c2..5b1633320e 100644 --- a/spring-integration-core/src/test/java/org/springframework/integration/configuration/EnableIntegrationTests.java +++ b/spring-integration-core/src/test/java/org/springframework/integration/configuration/EnableIntegrationTests.java @@ -923,7 +923,21 @@ public class EnableIntegrationTests { @Bean public PollableChannel publishedChannel() { - return new QueueChannel(); + return new QueueChannel() { + + @Override + protected boolean doSend(Message message, long timeout) { + logger.debug("---- 'publishedChannel' before 'doSend': " + message); + logger.debug("---- 'publishedChannel' state before: " + getQueueSize() + + ", " + getRemainingCapacity()); + boolean b = super.doSend(message, timeout); + logger.debug("---- 'publishedChannel' after 'doSend': " + b); + logger.debug("---- 'publishedChannel' state after: " + getQueueSize() + + ", " + getRemainingCapacity()); + return b; + } + + }; } @Bean