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

Increased receive timeouts for tests.

Browse Source
This commit is contained in:
Mark Fisher
2008-05-19 17:25:38 +00:00
parent 019ec2123d
commit 04dd70f764
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
spring-integration-core/src/test/java/org/springframework/integration/endpoint/ReturnAddressTests.java
View File

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