From ef1a0b2af53680e84b189a828c12a584d7af8b6c Mon Sep 17 00:00:00 2001
From: Mark Fisher <markfisher@vmware.com>
Date: Thu, 28 Feb 2008 00:23:01 +0000
Subject: [PATCH] Adjusted timing for test.

---
 .../integration/router/AggregatingMessageHandlerTests.java   | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/spring-integration-core/src/test/java/org/springframework/integration/router/AggregatingMessageHandlerTests.java b/spring-integration-core/src/test/java/org/springframework/integration/router/AggregatingMessageHandlerTests.java
index 4bf7ac2c28..414071d283 100644
--- a/spring-integration-core/src/test/java/org/springframework/integration/router/AggregatingMessageHandlerTests.java
+++ b/spring-integration-core/src/test/java/org/springframework/integration/router/AggregatingMessageHandlerTests.java
@@ -101,9 +101,10 @@ public class AggregatingMessageHandlerTests {
 		AggregatorTestTask task2 = new AggregatorTestTask(aggregator, message2, latch);
 		executor.execute(task1);
 		executor.execute(task2);
-		latch.await(1000, TimeUnit.MILLISECONDS);
+		latch.await(2000, TimeUnit.MILLISECONDS);
+		assertEquals("handlers should have been invoked within time limit", 0, latch.getCount());
 		Message<?> reply = replyChannel.receive(500);
-		assertNotNull(reply);
+		assertNotNull("a reply message should have been received", reply);
 		assertEquals("123456", reply.getPayload());
 		assertNull(task1.getException());
 		assertNull(task2.getException());