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

Upgrade dependencies

Browse Source 
* Gradle 6.1.1
* MongoDb 4.0
* Other Spring dependencies to `BUILD-SNAPSHOT`
* Fix MongoDb tests according latest Spring Data
* State in the docs that both MongoDb driver are `optional` now in the dependencies
This commit is contained in:
Artem Bilan
2020-02-03 13:12:50 -05:00
parent d792915be6
commit e5740f253c
25 changed files with 152 additions and 151 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -18,6 +18,7 @@ package org.springframework.integration.channel.reactive;
import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.assertThatExceptionOfType;
import static org.awaitility.Awaitility.await;
import static org.mockito.ArgumentMatchers.any;
import static org.mockito.BDDMockito.willAnswer;
import static org.mockito.Mockito.mock;
@@ -181,7 +182,9 @@ public class ReactiveStreamsConsumerTests {
BlockingQueue<Message<?>> messages = new LinkedBlockingQueue<>();
willAnswer(i -> {
messages.put(i.getArgument(0));
Message<?> message = i.getArgument(0);
LOGGER.debug("Polled message: " + message);
messages.put(message);
return null;
})
.given(testSubscriber)
@@ -220,6 +223,8 @@ public class ReactiveStreamsConsumerTests {
testChannel.send(testMessage2);
await().untilAsserted(() -> assertThat(messages).hasSizeGreaterThan(0));
LOGGER.debug("Messages to poll: " + messages);
message = messages.poll(10, TimeUnit.SECONDS);