diff --git a/org.springframework.integration.jms/src/test/java/org/springframework/integration/jms/JmsDestinationBackedMessageChannelTests.java b/org.springframework.integration.jms/src/test/java/org/springframework/integration/jms/JmsDestinationBackedMessageChannelTests.java index da8df0c70b..e0214fbb79 100644 --- a/org.springframework.integration.jms/src/test/java/org/springframework/integration/jms/JmsDestinationBackedMessageChannelTests.java +++ b/org.springframework.integration.jms/src/test/java/org/springframework/integration/jms/JmsDestinationBackedMessageChannelTests.java @@ -117,6 +117,7 @@ public class JmsDestinationBackedMessageChannelTests { channel.subscribe(handler1); channel.subscribe(handler2); channel.start(); + Thread.sleep(1000); // allow time for listener to subscribe channel.send(new StringMessage("foo")); channel.send(new StringMessage("bar")); latch.await(TIMEOUT, TimeUnit.MILLISECONDS);