You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2017/03/06 12:28:16 UTC
camel git commit: Fixed CS
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 <an...@gmail.com>
Authored: Mon Mar 6 13:27:50 2017 +0100
Committer: Andrea Cosentino <an...@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;