From 6e596a2c3f895e18dfe1086e936638f2aa66a911 Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Tue, 20 Apr 2010 22:19:38 +0000 Subject: [PATCH] Increase timeouts on UDP and JMS topic backed tests. --- .../ip/udp/DatagramPacketSendingHandlerTests.java | 8 ++++---- .../jms/JmsDestinationBackedMessageChannelTests.java | 2 +- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/org.springframework.integration.ip/src/test/java/org/springframework/integration/ip/udp/DatagramPacketSendingHandlerTests.java b/org.springframework.integration.ip/src/test/java/org/springframework/integration/ip/udp/DatagramPacketSendingHandlerTests.java index 7838c1d577..02de1b4f96 100644 --- a/org.springframework.integration.ip/src/test/java/org/springframework/integration/ip/udp/DatagramPacketSendingHandlerTests.java +++ b/org.springframework.integration.ip/src/test/java/org/springframework/integration/ip/udp/DatagramPacketSendingHandlerTests.java @@ -114,10 +114,10 @@ public class DatagramPacketSendingHandlerTests { } } }); - Thread.sleep(1000); + Thread.sleep(3000); String payload = "foobar"; handler.handleMessage(MessageBuilder.withPayload(payload).build()); - assertTrue(latch.await(3000, TimeUnit.MILLISECONDS)); + assertTrue(latch.await(10000, TimeUnit.MILLISECONDS)); byte[] src = receivedPacket.getData(); int length = receivedPacket.getLength(); int offset = receivedPacket.getOffset(); @@ -218,13 +218,13 @@ public class DatagramPacketSendingHandlerTests { Executor executor = Executors.newFixedThreadPool(2); executor.execute(catcher); executor.execute(catcher); - Thread.sleep(1000); + Thread.sleep(3000); MulticastSendingMessageHandler handler = new MulticastSendingMessageHandler(multicastAddress, testPort, true, true, "localhost", ackPort, 500000);; handler.setMinAcksForSuccess(2); handler.handleMessage(MessageBuilder.withPayload(payload).build()); - assertTrue(latch.await(3000, TimeUnit.MILLISECONDS)); + assertTrue(latch.await(10000, TimeUnit.MILLISECONDS)); handler.shutDown(); } 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 e0214fbb79..e145269d54 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,7 +117,7 @@ public class JmsDestinationBackedMessageChannelTests { channel.subscribe(handler1); channel.subscribe(handler2); channel.start(); - Thread.sleep(1000); // allow time for listener to subscribe + Thread.sleep(5000); // allow time for listener to subscribe channel.send(new StringMessage("foo")); channel.send(new StringMessage("bar")); latch.await(TIMEOUT, TimeUnit.MILLISECONDS);