diff --git a/spring-integration-core/src/test/java/org/springframework/integration/bus/MessageBusTests.java b/spring-integration-core/src/test/java/org/springframework/integration/bus/MessageBusTests.java index 3609bf84d9..ff79e0a50f 100644 --- a/spring-integration-core/src/test/java/org/springframework/integration/bus/MessageBusTests.java +++ b/spring-integration-core/src/test/java/org/springframework/integration/bus/MessageBusTests.java @@ -209,7 +209,7 @@ public class MessageBusTests { bus.registerHandler("testHandler", testHandler, new Subscription(testChannel)); bus.start(); for (int i = 0; i < 4; i++) { - assertTrue(testChannel.send(new StringMessage("test-"+ i), 100)); + assertTrue(testChannel.send(new StringMessage("test-"+ i), 1000)); } latch.await(1000, TimeUnit.MILLISECONDS); assertEquals(0, latch.getCount());