From fe8dca0785385b33e7f0ed7bd949ba01ea483da0 Mon Sep 17 00:00:00 2001
From: Gary Russell <grussell@vmware.com>
Date: Tue, 17 Aug 2010 00:49:11 +0000
Subject: [PATCH] INT-1346 Fix Test Timing Problem Where Second (expected)
 Failure Returned Before First (Good) Message.

---
 .../integration/ip/tcp/TcpOutboundGatewayTests.java        | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/TcpOutboundGatewayTests.java b/spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/TcpOutboundGatewayTests.java
index 0058d9dba3..cf5e64a666 100644
--- a/spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/TcpOutboundGatewayTests.java
+++ b/spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/TcpOutboundGatewayTests.java
@@ -199,10 +199,11 @@ public class TcpOutboundGatewayTests {
 		QueueChannel replyChannel = new QueueChannel();
 		gateway.setRequiresReply(true);
 		gateway.setOutputChannel(replyChannel);
-		List<Future<Integer>> results = new ArrayList<Future<Integer>>();
+		@SuppressWarnings("unchecked")
+		Future<Integer>[] results = new Future[2];
 		for (int i = 0; i < 2; i++) {
 			final int j = i;
-			results.add(Executors.newSingleThreadExecutor().submit(new Callable<Integer>(){
+			results[j] = (Executors.newSingleThreadExecutor().submit(new Callable<Integer>(){
 				public Integer call() throws Exception {
 					gateway.handleMessage(MessageBuilder.withPayload("Test" + j).build());
 					return 0;
@@ -212,7 +213,7 @@ public class TcpOutboundGatewayTests {
 		Set<String> replies = new HashSet<String>();
 		for (int i = 0; i < 2; i++) { 
 			try {
-				results.get(i).get();
+				results[i].get();
 			} catch (InterruptedException e) {
 				
 			} catch (ExecutionException e) {