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 911e852182..64a3ea626d 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 @@ -81,7 +81,7 @@ public class JmsDestinationBackedMessageChannelTests { channel.subscribe(handler2); channel.send(new StringMessage("foo")); channel.send(new StringMessage("bar")); - latch.await(3000, TimeUnit.MILLISECONDS); + latch.await(5000, TimeUnit.MILLISECONDS); assertEquals(1, receivedList1.size()); assertNotNull(receivedList1.get(0)); assertEquals("foo", receivedList1.get(0).getPayload()); @@ -114,7 +114,7 @@ public class JmsDestinationBackedMessageChannelTests { channel.subscribe(handler2); channel.send(new StringMessage("foo")); channel.send(new StringMessage("bar")); - latch.await(3000, TimeUnit.MILLISECONDS); + latch.await(5000, TimeUnit.MILLISECONDS); assertEquals(2, receivedList1.size()); assertEquals("foo", receivedList1.get(0).getPayload()); assertEquals("bar", receivedList1.get(1).getPayload()); @@ -147,7 +147,7 @@ public class JmsDestinationBackedMessageChannelTests { channel.subscribe(handler2); channel.send(new StringMessage("foo")); channel.send(new StringMessage("bar")); - latch.await(3000, TimeUnit.MILLISECONDS); + latch.await(5000, TimeUnit.MILLISECONDS); assertEquals(1, receivedList1.size()); assertNotNull(receivedList1.get(0)); assertEquals("foo", receivedList1.get(0).getPayload()); @@ -180,7 +180,7 @@ public class JmsDestinationBackedMessageChannelTests { channel.subscribe(handler2); channel.send(new StringMessage("foo")); channel.send(new StringMessage("bar")); - latch.await(3000, TimeUnit.MILLISECONDS); + latch.await(5000, TimeUnit.MILLISECONDS); assertEquals(2, receivedList1.size()); assertEquals("foo", receivedList1.get(0).getPayload()); assertEquals("bar", receivedList1.get(1).getPayload());