From 34bc8116df4de6f2013e36c2bbcb3e82ed7d5155 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Thu, 30 Jan 2020 17:58:40 -0500 Subject: [PATCH] Add `@LogLevels` to ReactiveStreamsConsumerTests https://build.spring.io/browse/INT-MASTERSPRING40-967/ --- .../channel/reactive/ReactiveStreamsConsumerTests.java | 2 ++ 1 file changed, 2 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 549ab3fecc..731defc9fd 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 @@ -46,6 +46,7 @@ import org.springframework.integration.channel.QueueChannel; import org.springframework.integration.config.ConsumerEndpointFactoryBean; import org.springframework.integration.endpoint.ReactiveStreamsConsumer; import org.springframework.integration.handler.MethodInvokingMessageHandler; +import org.springframework.integration.test.condition.LogLevels; import org.springframework.messaging.Message; import org.springframework.messaging.MessageDeliveryException; import org.springframework.messaging.MessageHandler; @@ -165,6 +166,7 @@ public class ReactiveStreamsConsumerTests { reactiveConsumer.stop(); } + @LogLevels(level = "trace", categories = "org.springframework.integration") @Test @SuppressWarnings("unchecked") public void testReactiveStreamsConsumerPollableChannel() throws InterruptedException {