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);