Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add log() to test Publisher for diagnostics

Browse Source 
https://build.spring.io/browse/INT-MASTER-1916/
This commit is contained in:
Artem Bilan
2020-02-27 18:12:31 -05:00
parent bd9563bd1e
commit 0e5258a661
1 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
spring-integration-core/src/test/java/org/springframework/integration/channel/reactive/ReactiveStreamsConsumerTests.java
View File

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