increased timeouts
This commit is contained in:
@@ -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());
|
||||
|
||||
Reference in New Issue
Block a user