From d792915be675c43b7d4f524fe902fef88bd710f5 Mon Sep 17 00:00:00 2001
From: Artem Bilan <abilan@pivotal.io>
Date: Fri, 31 Jan 2020 15:16:57 -0500
Subject: [PATCH] Add debug log for ReactiveStreamsConsumerTests

https://build.spring.io/browse/INT-MASTER-1883/
---
 .../channel/reactive/ReactiveStreamsConsumerTests.java      | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/spring-integration-core/src/test/java/org/springframework/integration/channel/reactive/ReactiveStreamsConsumerTests.java b/spring-integration-core/src/test/java/org/springframework/integration/channel/reactive/ReactiveStreamsConsumerTests.java
index 731defc9fd..abd543b718 100644
--- a/spring-integration-core/src/test/java/org/springframework/integration/channel/reactive/ReactiveStreamsConsumerTests.java
+++ b/spring-integration-core/src/test/java/org/springframework/integration/channel/reactive/ReactiveStreamsConsumerTests.java
@@ -32,6 +32,8 @@ import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.LinkedBlockingQueue;
 import java.util.concurrent.TimeUnit;
 
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
 import org.junit.jupiter.api.Test;
 import org.mockito.ArgumentCaptor;
 import org.mockito.Mockito;
@@ -64,6 +66,8 @@ import reactor.test.StepVerifier;
  */
 public class ReactiveStreamsConsumerTests {
 
+	private static final Log LOGGER = LogFactory.getLog(ReactiveStreamsConsumerTests.class);
+
 	@Test
 	public void testReactiveStreamsConsumerFluxMessageChannel() throws InterruptedException {
 		FluxMessageChannel testChannel = new FluxMessageChannel();
@@ -216,6 +220,8 @@ public class ReactiveStreamsConsumerTests {
 
 		testChannel.send(testMessage2);
 
+		LOGGER.debug("Messages to poll: " + messages);
+
 		message = messages.poll(10, TimeUnit.SECONDS);
 		assertThat(message).isSameAs(testMessage);