From 0e5258a661c3581580c9df73a5bd64683e6a31d2 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Thu, 27 Feb 2020 18:12:31 -0500 Subject: [PATCH] Add `log()` to test `Publisher` for diagnostics https://build.spring.io/browse/INT-MASTER-1916/ --- .../channel/reactive/ReactiveStreamsConsumerTests.java | 9 +++++++++ 1 file changed, 9 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 fad351b1bc..3d8d6baad4 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 @@ -41,6 +41,7 @@ import org.mockito.Mockito; import org.reactivestreams.Subscriber; import org.reactivestreams.Subscription; +import org.springframework.beans.DirectFieldAccessor; import org.springframework.beans.factory.BeanFactory; import org.springframework.beans.factory.config.ConfigurableBeanFactory; import org.springframework.integration.channel.DirectChannel; @@ -57,8 +58,10 @@ import org.springframework.messaging.ReactiveMessageHandler; import org.springframework.messaging.support.GenericMessage; import reactor.core.publisher.EmitterProcessor; +import reactor.core.publisher.Flux; import reactor.core.publisher.Mono; import reactor.test.StepVerifier; +import reactor.util.Loggers; /** * @author Artem Bilan @@ -191,6 +194,12 @@ public class ReactiveStreamsConsumerTests { .onNext(any(Message.class)); ReactiveStreamsConsumer reactiveConsumer = new ReactiveStreamsConsumer(testChannel, testSubscriber); + + DirectFieldAccessor dfa = new DirectFieldAccessor(reactiveConsumer); + Flux publisher = (Flux) dfa.getPropertyValue("publisher"); + publisher = publisher.log(Loggers.getLogger(ReactiveStreamsConsumerTests.class)); + dfa.setPropertyValue("publisher", publisher); + reactiveConsumer.setBeanFactory(mock(BeanFactory.class)); reactiveConsumer.afterPropertiesSet(); reactiveConsumer.start();