From 2feb6bf81c1a6ebd19812f020e4b1bdf6d822bf9 Mon Sep 17 00:00:00 2001
From: Mark Fisher <markfisher@vmware.com>
Date: Thu, 29 Apr 2010 19:29:16 +0000
Subject: [PATCH] clearing thread-local queue before each test method

---
 .../integration/channel/ThreadLocalChannelTests.java  | 11 +++++++++++
 1 file changed, 11 insertions(+)

diff --git a/org.springframework.integration/src/test/java/org/springframework/integration/channel/ThreadLocalChannelTests.java b/org.springframework.integration/src/test/java/org/springframework/integration/channel/ThreadLocalChannelTests.java
index 9a1795d757..f2575e3a3f 100644
--- a/org.springframework.integration/src/test/java/org/springframework/integration/channel/ThreadLocalChannelTests.java
+++ b/org.springframework.integration/src/test/java/org/springframework/integration/channel/ThreadLocalChannelTests.java
@@ -24,6 +24,7 @@ import static org.junit.Assert.assertTrue;
 import java.util.ArrayList;
 import java.util.List;
 
+import org.junit.Before;
 import org.junit.Test;
 
 import org.springframework.integration.core.Message;
@@ -34,6 +35,16 @@ import org.springframework.integration.message.StringMessage;
  */
 public class ThreadLocalChannelTests {
 
+	@Before
+	public void clearThreadLocalQueue() {
+		ThreadLocalChannel channel = new ThreadLocalChannel();
+		Message<?> result = null;
+		do {
+			result = channel.receive(0);
+		} while (result != null);
+	}
+
+
 	@Test
 	public void testSendAndReceive() {
 		ThreadLocalChannel channel = new ThreadLocalChannel();