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

Debug ReactiveStreamsTest

Browse Source 
https://build.spring.io/browse/INT-MASTER-436
This commit is contained in:
Gary Russell
2016-11-19 12:06:24 -05:00
parent 849e3538de
commit 3d668d5d35
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-integration-core/src/test/java/org/springframework/integration/dsl/reactivestreams/ReactiveStreamsTests.java
View File

@@ -34,6 +34,8 @@ import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
import java.util.concurrent.atomic.AtomicBoolean;
import org.apache.log4j.Level;
import org.junit.Rule;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.reactivestreams.Publisher;
@@ -47,6 +49,7 @@ import org.springframework.integration.IntegrationMessageHeaderAccessor;
import org.springframework.integration.config.EnableIntegration;
import org.springframework.integration.dsl.IntegrationFlows;
import org.springframework.integration.dsl.channel.MessageChannels;
import org.springframework.integration.test.rule.Log4jLevelAdjuster;
import org.springframework.messaging.Message;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.support.GenericMessage;
@@ -65,6 +68,9 @@ import reactor.core.publisher.Flux;
@DirtiesContext
public class ReactiveStreamsTests {
@Rule
public Log4jLevelAdjuster adjuster = new Log4jLevelAdjuster(Level.DEBUG, "org.springframework.integration");
@Autowired
@Qualifier("reactiveFlow")
private Publisher<Message<String>> publisher;