From 842af05441e91465504b5b27294466f3bf2499bf Mon Sep 17 00:00:00 2001
From: Oleg Zhurakousky <ozhurakousky@vmware.com>
Date: Tue, 3 May 2011 18:57:13 -0400
Subject: [PATCH] polished PollingLifecycleTests making it more reliable

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

diff --git a/spring-integration-core/src/test/java/org/springframework/integration/endpoint/PollingLifecycleTests.java b/spring-integration-core/src/test/java/org/springframework/integration/endpoint/PollingLifecycleTests.java
index 3cfa806afa..9345a881bc 100644
--- a/spring-integration-core/src/test/java/org/springframework/integration/endpoint/PollingLifecycleTests.java
+++ b/spring-integration-core/src/test/java/org/springframework/integration/endpoint/PollingLifecycleTests.java
@@ -126,14 +126,12 @@ public class PollingLifecycleTests {
 		pollerMetadata.setMaxMessagesPerPoll(-1);
 		pollerMetadata.setTrigger(new PeriodicTrigger(2000));
 		adapterFactory.setPollerMetadata(pollerMetadata);
-		final Runnable runnable = mock(Runnable.class);
 		final Runnable coughtInterrupted = mock(Runnable.class);
 		MessageSource<String> source = new MessageSource<String>() {
 			public Message<String> receive() {
 				
 				try {
-					for (int i = 0; i < 10; i++) {
-						runnable.run();				
+					for (int i = 0; i < 10; i++) {			
 						Thread.sleep(1000);
 						latch.countDown();
 					}
@@ -154,6 +152,7 @@ public class PollingLifecycleTests {
 		assertTrue(latch.await(3000, TimeUnit.SECONDS));
 		//
 		adapter.stop();
+		Thread.sleep(1000);
 		Mockito.verify(coughtInterrupted, times(1)).run();
 	}
 }