EnableIntegrationTests: add more logger.debug

2015-02-23 11:57:56 +02:00
parent d8c369d4d3
commit 49c231e547
1 changed files with 15 additions and 1 deletions
--- 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