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

INT-4332: Fix Test Race Condition

Browse Source
This commit is contained in:
Gary Russell
2017-08-23 09:52:52 -04:00
parent 318741d1fd
commit 34652f3342
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
spring-integration-core/src/test/java/org/springframework/integration/dsl/flows/IntegrationFlowTests.java
View File

@@ -183,7 +183,6 @@ public class IntegrationFlowTests {
@Test
public void testWithSupplierMessageSourceProvidedPoller() {
assertNull(this.suppliedChannel2.receive(100));
assertEquals("FOO", this.suppliedChannel2.receive(2000).getPayload());
}
@@ -514,7 +513,7 @@ public class IntegrationFlowTests {
public static class SupplierContextConfiguration2 {
@Bean
public IntegrationFlow supplierFlow2() {
return IntegrationFlows.from(() -> "foo", c -> c.poller(Pollers.fixedDelay(400, 300).maxMessagesPerPoll(1)))
return IntegrationFlows.from(() -> "foo", c -> c.poller(Pollers.fixedDelay(100).maxMessagesPerPoll(1)))
.<String, String>transform(p -> p.toUpperCase())
.channel("suppliedChannel2")
.get();