From 5edc817849ff25bb29513e335a89340e693b120d Mon Sep 17 00:00:00 2001
From: Mark Fisher <markfisher@vmware.com>
Date: Fri, 29 Apr 2011 15:34:03 -0400
Subject: [PATCH] INT-1853 added extra check on loop condition for
 'initialized'

---
 .../integration/endpoint/AbstractPollingEndpoint.java           | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/spring-integration-core/src/main/java/org/springframework/integration/endpoint/AbstractPollingEndpoint.java b/spring-integration-core/src/main/java/org/springframework/integration/endpoint/AbstractPollingEndpoint.java
index 2a2172fa4a..049a720007 100644
--- a/spring-integration-core/src/main/java/org/springframework/integration/endpoint/AbstractPollingEndpoint.java
+++ b/spring-integration-core/src/main/java/org/springframework/integration/endpoint/AbstractPollingEndpoint.java
@@ -201,7 +201,7 @@ public abstract class AbstractPollingEndpoint extends AbstractEndpoint implement
 			taskExecutor.execute(new Runnable() {
 				public void run() {
 					int count = 0;
-					while (maxMessagesPerPoll <= 0 || count < maxMessagesPerPoll) {
+					while (initialized && (maxMessagesPerPoll <= 0 || count < maxMessagesPerPoll)) {
 						try {
 							if (!pollingTask.call()) {
 								break;