From 34652f3342d6ff71a28d02d10cf3df0cb5a2d05a Mon Sep 17 00:00:00 2001
From: Gary Russell <grussell@pivotal.io>
Date: Wed, 23 Aug 2017 09:52:52 -0400
Subject: [PATCH] INT-4332: Fix Test Race Condition

---
 .../integration/dsl/flows/IntegrationFlowTests.java            | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

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)))
 					.<String, String>transform(p -> p.toUpperCase())
 					.channel("suppliedChannel2")
 					.get();