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 06e0f04717..c2dba0e660 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 @@ -172,8 +172,8 @@ public abstract class AbstractPollingEndpoint extends AbstractEndpoint implement int count = 0; while (maxMessagesPerPoll <= 0 || count < maxMessagesPerPoll) { try { - boolean b = pollingTask.call(); - if (!b){ + boolean computed = pollingTask.call(); + if (!computed){ break; } count++;