diff --git a/spring-integration-core/src/test/java/org/springframework/integration/dsl/flows/IntegrationFlowTests.java b/spring-integration-core/src/test/java/org/springframework/integration/dsl/flows/IntegrationFlowTests.java index b9a88b1539..3e5c08d714 100644 --- a/spring-integration-core/src/test/java/org/springframework/integration/dsl/flows/IntegrationFlowTests.java +++ b/spring-integration-core/src/test/java/org/springframework/integration/dsl/flows/IntegrationFlowTests.java @@ -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))) .transform(p -> p.toUpperCase()) .channel("suppliedChannel2") .get();