You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2015/10/11 18:26:09 UTC
[2/2] camel git commit: That option is a filter option.
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/2890a2f2
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/2890a2f2
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/2890a2f2
Branch: refs/heads/camel-2.16.x
Commit: 2890a2f262c2be0b8c9c0410481df3cb5bcb0868
Parents: e56c64e
Author: Claus Ibsen <da...@apache.org>
Authored: Sun Oct 11 17:45:08 2015 +0200
Committer: Claus Ibsen <da...@apache.org>
Committed: Sun Oct 11 18:28:20 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/2890a2f2/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/2890a2f2/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) {