Repository: camel Updated Branches: refs/heads/camel-2.16.x e56c64e1f -> 2890a2f26 refs/heads/master a2ba808d4 -> f6458e9cb
That option is a filter option. Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/f6458e9c Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/f6458e9c Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/f6458e9c Branch: refs/heads/master Commit: f6458e9cbfe869246466243648156fb5eda2e09d Parents: a2ba808 Author: Claus Ibsen <[email protected]> Authored: Sun Oct 11 17:45:08 2015 +0200 Committer: Claus Ibsen <[email protected]> Committed: Sun Oct 11 17:45:15 2015 +0200 ---------------------------------------------------------------------- .../java/org/apache/camel/component/file/GenericFileEndpoint.java | 2 +- .../java/org/apache/camel/impl/ScheduledBatchPollingConsumer.java | 2 -- 2 files changed, 1 insertion(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/f6458e9c/camel-core/src/main/java/org/apache/camel/component/file/GenericFileEndpoint.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/component/file/GenericFileEndpoint.java b/camel-core/src/main/java/org/apache/camel/component/file/GenericFileEndpoint.java index 5d45706..25dbb74 100644 --- a/camel-core/src/main/java/org/apache/camel/component/file/GenericFileEndpoint.java +++ b/camel-core/src/main/java/org/apache/camel/component/file/GenericFileEndpoint.java @@ -117,7 +117,7 @@ public abstract class GenericFileEndpoint<T> extends ScheduledPollEndpoint imple protected boolean recursive; @UriParam(label = "consumer") protected boolean delete; - @UriParam(label = "consumer") + @UriParam(label = "consumer,filter") protected int maxMessagesPerPoll; @UriParam(label = "consumer,filter", defaultValue = "true") protected boolean eagerMaxMessagesPerPoll = true; http://git-wip-us.apache.org/repos/asf/camel/blob/f6458e9c/camel-core/src/main/java/org/apache/camel/impl/ScheduledBatchPollingConsumer.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/impl/ScheduledBatchPollingConsumer.java b/camel-core/src/main/java/org/apache/camel/impl/ScheduledBatchPollingConsumer.java index a39263c..661eb7a 100644 --- a/camel-core/src/main/java/org/apache/camel/impl/ScheduledBatchPollingConsumer.java +++ b/camel-core/src/main/java/org/apache/camel/impl/ScheduledBatchPollingConsumer.java @@ -24,7 +24,6 @@ import org.apache.camel.Exchange; import org.apache.camel.Processor; import org.apache.camel.ShutdownRunningTask; import org.apache.camel.spi.ShutdownAware; -import org.apache.camel.spi.UriParam; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -35,7 +34,6 @@ public abstract class ScheduledBatchPollingConsumer extends ScheduledPollConsume private static final Logger LOG = LoggerFactory.getLogger(ScheduledBatchPollingConsumer.class); protected volatile ShutdownRunningTask shutdownRunningTask; protected volatile int pendingExchanges; - @UriParam protected int maxMessagesPerPoll; public ScheduledBatchPollingConsumer(Endpoint endpoint, Processor processor) {
