From 215e10a6eb448793b37b09c7cbbf78cb8d2c40cc Mon Sep 17 00:00:00 2001
From: Mark Fisher <markfisher@vmware.com>
Date: Mon, 11 Aug 2008 20:16:55 +0000
Subject: [PATCH] Added test timeouts for Message reception.

---
 .../endpoint/interceptor/TransactionInterceptorTests.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/org.springframework.integration/src/test/java/org/springframework/integration/endpoint/interceptor/TransactionInterceptorTests.java b/org.springframework.integration/src/test/java/org/springframework/integration/endpoint/interceptor/TransactionInterceptorTests.java
index c2eac923be..a0692be40a 100644
--- a/org.springframework.integration/src/test/java/org/springframework/integration/endpoint/interceptor/TransactionInterceptorTests.java
+++ b/org.springframework.integration/src/test/java/org/springframework/integration/endpoint/interceptor/TransactionInterceptorTests.java
@@ -51,7 +51,7 @@ public class TransactionInterceptorTests {
 		assertEquals(0, txManager.getRollbackCount());
 		input.send(new StringMessage("test"));
 		txManager.waitForCompletion(1000);
-		Message<?> message = output.receive(0);
+		Message<?> message = output.receive(500);
 		assertNotNull(message);		
 		assertEquals(1, txManager.getCommitCount());
 		assertEquals(0, txManager.getRollbackCount());		
@@ -68,7 +68,7 @@ public class TransactionInterceptorTests {
 		assertEquals(0, txManager.getRollbackCount());
 		input.send(new StringMessage("test"));
 		txManager.waitForCompletion(1000);
-		Message<?> message = output.receive(0);
+		Message<?> message = output.receive(500);
 		assertNull(message);
 		assertEquals(0, txManager.getCommitCount());
 		assertEquals(1, txManager.getRollbackCount());