From f5ff24b7066caba730a6a86ee55897d51d9f9b1f Mon Sep 17 00:00:00 2001 From: Mark Fisher Date: Tue, 3 Nov 2009 16:46:40 +0000 Subject: [PATCH] increased test timeout --- .../jms/JmsDestinationBackedMessageChannelTests.java | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) 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 b2e1a5c355..74233bae46 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 @@ -39,6 +39,9 @@ import java.util.concurrent.TimeUnit; */ public class JmsDestinationBackedMessageChannelTests { + private static final int TIMEOUT = 10000; + + private ActiveMQConnectionFactory connectionFactory; private Destination topic; @@ -78,7 +81,7 @@ public class JmsDestinationBackedMessageChannelTests { channel.subscribe(handler2); channel.send(new StringMessage("foo")); channel.send(new StringMessage("bar")); - latch.await(5000, TimeUnit.MILLISECONDS); + latch.await(TIMEOUT, TimeUnit.MILLISECONDS); assertEquals(1, receivedList1.size()); assertNotNull(receivedList1.get(0)); assertEquals("foo", receivedList1.get(0).getPayload()); @@ -111,7 +114,7 @@ public class JmsDestinationBackedMessageChannelTests { channel.subscribe(handler2); channel.send(new StringMessage("foo")); channel.send(new StringMessage("bar")); - latch.await(5000, TimeUnit.MILLISECONDS); + latch.await(TIMEOUT, TimeUnit.MILLISECONDS); assertEquals(2, receivedList1.size()); assertEquals("foo", receivedList1.get(0).getPayload()); assertEquals("bar", receivedList1.get(1).getPayload()); @@ -144,7 +147,7 @@ public class JmsDestinationBackedMessageChannelTests { channel.subscribe(handler2); channel.send(new StringMessage("foo")); channel.send(new StringMessage("bar")); - latch.await(5000, TimeUnit.MILLISECONDS); + latch.await(TIMEOUT, TimeUnit.MILLISECONDS); assertEquals(1, receivedList1.size()); assertNotNull(receivedList1.get(0)); assertEquals("foo", receivedList1.get(0).getPayload()); @@ -177,7 +180,7 @@ public class JmsDestinationBackedMessageChannelTests { channel.subscribe(handler2); channel.send(new StringMessage("foo")); channel.send(new StringMessage("bar")); - latch.await(5000, TimeUnit.MILLISECONDS); + latch.await(TIMEOUT, TimeUnit.MILLISECONDS); assertEquals(2, receivedList1.size()); assertEquals("foo", receivedList1.get(0).getPayload()); assertEquals("bar", receivedList1.get(1).getPayload());