From 04dd70f764acfeac8ddb22f594d8399e600709c3 Mon Sep 17 00:00:00 2001 From: Mark Fisher Date: Mon, 19 May 2008 17:25:38 +0000 Subject: [PATCH] Increased receive timeouts for tests. --- .../integration/endpoint/ReturnAddressTests.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/spring-integration-core/src/test/java/org/springframework/integration/endpoint/ReturnAddressTests.java b/spring-integration-core/src/test/java/org/springframework/integration/endpoint/ReturnAddressTests.java index c2f4681a6d..fa370ad608 100644 --- a/spring-integration-core/src/test/java/org/springframework/integration/endpoint/ReturnAddressTests.java +++ b/spring-integration-core/src/test/java/org/springframework/integration/endpoint/ReturnAddressTests.java @@ -41,7 +41,7 @@ public class ReturnAddressTests { StringMessage message = new StringMessage("*"); message.getHeader().setReturnAddress("replyChannel"); channel1.send(message); - Message response = replyChannel.receive(1000); + Message response = replyChannel.receive(3000); assertNotNull(response); assertEquals("**", response.getPayload()); } @@ -56,7 +56,7 @@ public class ReturnAddressTests { StringMessage message = new StringMessage("*"); message.getHeader().setReturnAddress("replyChannel"); channel1.send(message); - Message response = replyChannel.receive(1000); + Message response = replyChannel.receive(3000); assertNotNull(response); assertEquals("********", response.getPayload()); } @@ -70,7 +70,7 @@ public class ReturnAddressTests { context.start(); StringMessage message = new StringMessage("*"); channel4.send(message); - Message response = replyChannel.receive(1000); + Message response = replyChannel.receive(3000); assertNotNull(response); assertEquals("**", response.getPayload()); } @@ -84,7 +84,7 @@ public class ReturnAddressTests { context.start(); StringMessage message = new StringMessage("*"); channel3.send(message); - Message errorMessage = errorChannel.receive(1000); + Message errorMessage = errorChannel.receive(3000); assertNotNull(errorMessage.getPayload()); } @@ -97,7 +97,7 @@ public class ReturnAddressTests { context.start(); StringMessage message = new StringMessage("*"); channel3.send(message); - Message errorMessage = errorChannel.receive(1000); + Message errorMessage = errorChannel.receive(3000); assertNotNull(errorMessage.getPayload()); }