Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

INT-1853 added extra check on loop condition for 'initialized'

Browse Source
This commit is contained in:
Mark Fisher
2011-04-29 15:34:03 -04:00
parent ade987d49c
commit 5edc817849
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-integration-core/src/main/java/org/springframework/integration/endpoint/AbstractPollingEndpoint.java
View File

@@ -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;