Repository: camel Updated Branches: refs/heads/camel-2.17.x 5aa518ef6 -> bd9f9077e
Fixed CS Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/bd9f9077 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/bd9f9077 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/bd9f9077 Branch: refs/heads/camel-2.17.x Commit: bd9f9077ef9bf7eb98bd793e9521ae5ba0d93ce1 Parents: 5aa518e Author: Andrea Cosentino <anco...@gmail.com> Authored: Mon Mar 6 13:27:50 2017 +0100 Committer: Andrea Cosentino <anco...@gmail.com> Committed: Mon Mar 6 13:32:49 2017 +0100 ---------------------------------------------------------------------- .../main/java/org/apache/camel/component/hdfs2/HdfsConsumer.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/bd9f9077/components/camel-hdfs2/src/main/java/org/apache/camel/component/hdfs2/HdfsConsumer.java ---------------------------------------------------------------------- diff --git a/components/camel-hdfs2/src/main/java/org/apache/camel/component/hdfs2/HdfsConsumer.java b/components/camel-hdfs2/src/main/java/org/apache/camel/component/hdfs2/HdfsConsumer.java index 8bb17b8..3d5d8d4 100644 --- a/components/camel-hdfs2/src/main/java/org/apache/camel/component/hdfs2/HdfsConsumer.java +++ b/components/camel-hdfs2/src/main/java/org/apache/camel/component/hdfs2/HdfsConsumer.java @@ -35,14 +35,14 @@ import org.apache.hadoop.fs.PathFilter; public final class HdfsConsumer extends ScheduledPollConsumer { + public static final long DEFAULT_CONSUMER_INITIAL_DELAY = 10 * 1000L; + private final HdfsConfiguration config; private final StringBuilder hdfsPath; private final Processor processor; private final ReadWriteLock rwlock = new ReentrantReadWriteLock(); private volatile HdfsInputStream istream; - public static final long DEFAULT_CONSUMER_INITIAL_DELAY = 10 * 1000L; - public HdfsConsumer(HdfsEndpoint endpoint, Processor processor, HdfsConfiguration config) { super(endpoint, processor); this.config = config;
