From e5b2a2a9aa746b504ec464f20d51a1a5bc096b73 Mon Sep 17 00:00:00 2001
From: Mark Fisher <markfisher@vmware.com>
Date: Thu, 10 Apr 2008 11:34:52 +0000
Subject: [PATCH] Added timeout to receive calls.

---
 .../adapter/stream/CharacterStreamSourceAdapterTests.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/spring-integration-adapters/src/test/java/org/springframework/integration/adapter/stream/CharacterStreamSourceAdapterTests.java b/spring-integration-adapters/src/test/java/org/springframework/integration/adapter/stream/CharacterStreamSourceAdapterTests.java
index 1bbf2455e9..3b59f277d5 100644
--- a/spring-integration-adapters/src/test/java/org/springframework/integration/adapter/stream/CharacterStreamSourceAdapterTests.java
+++ b/spring-integration-adapters/src/test/java/org/springframework/integration/adapter/stream/CharacterStreamSourceAdapterTests.java
@@ -98,9 +98,9 @@ public class CharacterStreamSourceAdapterTests {
 		adapter.start();
 		int count = adapter.processMessages();
 		assertEquals(2, count);
-		Message<?> message1 = channel.receive(0);
+		Message<?> message1 = channel.receive(500);
 		assertEquals("test1", message1.getPayload());
-		Message<?> message2 = channel.receive(0);
+		Message<?> message2 = channel.receive(500);
 		assertEquals("test2", message2.getPayload());
 		Message<?> message3 = channel.receive(0);
 		assertNull(message3);