From 3254c132d2a790b5189c9e7fecaa649d334302a9 Mon Sep 17 00:00:00 2001
From: Mark Fisher <markfisher@vmware.com>
Date: Wed, 16 Jan 2008 02:24:54 +0000
Subject: [PATCH] Added timeout value.

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

diff --git a/spring-integration-core/src/test/java/org/springframework/integration/adapter/stream/ByteStreamSourceAdapterTests.java b/spring-integration-core/src/test/java/org/springframework/integration/adapter/stream/ByteStreamSourceAdapterTests.java
index f72cd991c7..46cf2ef0b4 100644
--- a/spring-integration-core/src/test/java/org/springframework/integration/adapter/stream/ByteStreamSourceAdapterTests.java
+++ b/spring-integration-core/src/test/java/org/springframework/integration/adapter/stream/ByteStreamSourceAdapterTests.java
@@ -42,7 +42,7 @@ public class ByteStreamSourceAdapterTests {
 		adapter.start();
 		int count = adapter.processMessages();
 		assertEquals(1, count);
-		Message<?> message1 = channel.receive(0);
+		Message<?> message1 = channel.receive(500);
 		byte[] payload = (byte[]) message1.getPayload();
 		assertEquals(3, payload.length);
 		assertEquals(1, payload[0]);
@@ -67,7 +67,7 @@ public class ByteStreamSourceAdapterTests {
 		adapter.start();
 		int count = adapter.processMessages();
 		assertEquals(1, count);
-		Message<?> message1 = channel.receive(0);
+		Message<?> message1 = channel.receive(500);
 		assertEquals(8, ((byte[]) message1.getPayload()).length);
 		Message<?> message2 = channel.receive(0);
 		assertNull(message2);