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

Add debug log for ReactiveStreamsConsumerTests

Browse Source 
https://build.spring.io/browse/INT-MASTER-1883/
This commit is contained in:
Artem Bilan
2020-01-31 15:16:57 -05:00
parent 2f4394d8b5
commit d792915be6
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/channel/reactive/ReactiveStreamsConsumerTests.java
View File

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