Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

increased test timeout

Browse Source
This commit is contained in:
Mark Fisher
2009-11-03 16:46:40 +00:00
parent e01d8a06b1
commit f5ff24b706
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
org.springframework.integration.jms/src/test/java/org/springframework/integration/jms/JmsDestinationBackedMessageChannelTests.java
View File

@@ -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());