Repository: camel Updated Branches: refs/heads/master 70ea98262 -> a7f07849d
fix misleading debug log message concerning the number of polled messages Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/401a6686 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/401a6686 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/401a6686 Branch: refs/heads/master Commit: 401a6686314248dc22257145e2feb24592670aa6 Parents: e784761 Author: Pascal Schumacher <pascalschumac...@gmx.net> Authored: Fri Jun 17 18:30:18 2016 +0200 Committer: Pascal Schumacher <pascalschumac...@gmx.net> Committed: Fri Jun 17 18:30:18 2016 +0200 ---------------------------------------------------------------------- .../src/main/java/org/apache/camel/component/sql/SqlConsumer.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/401a6686/components/camel-sql/src/main/java/org/apache/camel/component/sql/SqlConsumer.java ---------------------------------------------------------------------- diff --git a/components/camel-sql/src/main/java/org/apache/camel/component/sql/SqlConsumer.java b/components/camel-sql/src/main/java/org/apache/camel/component/sql/SqlConsumer.java index ab48133..bc72d6e 100644 --- a/components/camel-sql/src/main/java/org/apache/camel/component/sql/SqlConsumer.java +++ b/components/camel-sql/src/main/java/org/apache/camel/component/sql/SqlConsumer.java @@ -210,9 +210,8 @@ public class SqlConsumer extends ScheduledBatchPollingConsumer { public int processBatch(Queue<Object> exchanges) throws Exception { int total = exchanges.size(); - // limit if needed if (maxMessagesPerPoll > 0 && total == maxMessagesPerPoll) { - log.debug("Limiting to maximum messages to poll " + maxMessagesPerPoll + " as there was more messages in this poll."); + log.debug("Maximum messages to poll is {} and there were exactly {} messages in this poll.", maxMessagesPerPoll, total); } for (int index = 0; index < total && isBatchAllowed(); index++) {
