Repository: camel Updated Branches: refs/heads/master cf303d761 -> 50a9e4f16
Fixed CS Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/50a9e4f1 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/50a9e4f1 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/50a9e4f1 Branch: refs/heads/master Commit: 50a9e4f1663f3012cce20c6dd6f0592f7329dee3 Parents: cf303d7 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:27:50 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/50a9e4f1/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;
