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 2016/01/16 12:40:19 UTC
[3/8] camel git commit: camel-hdfs - should extend poll endpoint as
the consumer is poll based.
camel-hdfs - should extend poll endpoint as the consumer is poll based.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/94c197ab
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/94c197ab
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/94c197ab
Branch: refs/heads/master
Commit: 94c197aba001c1ef1a330e62ff2643d57a282a25
Parents: 5d69ca2
Author: Claus Ibsen <da...@apache.org>
Authored: Sat Jan 16 12:33:20 2016 +0100
Committer: Claus Ibsen <da...@apache.org>
Committed: Sat Jan 16 12:33:20 2016 +0100
----------------------------------------------------------------------
.../main/java/org/apache/camel/component/hdfs/HdfsEndpoint.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/94c197ab/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsEndpoint.java b/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsEndpoint.java
index bae2b58..4d809f9 100644
--- a/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsEndpoint.java
+++ b/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsEndpoint.java
@@ -23,7 +23,7 @@ import org.apache.camel.CamelContext;
import org.apache.camel.Consumer;
import org.apache.camel.Processor;
import org.apache.camel.Producer;
-import org.apache.camel.impl.DefaultEndpoint;
+import org.apache.camel.impl.ScheduledPollEndpoint;
import org.apache.camel.spi.UriEndpoint;
import org.apache.camel.spi.UriParam;
@@ -31,7 +31,7 @@ import org.apache.camel.spi.UriParam;
* For reading/writing from/to an HDFS filesystem using Hadoop 1.x.
*/
@UriEndpoint(scheme = "hdfs", title = "HDFS", syntax = "hdfs:hostName:port/path", consumerClass = HdfsConsumer.class, label = "hadoop,file")
-public class HdfsEndpoint extends DefaultEndpoint {
+public class HdfsEndpoint extends ScheduledPollEndpoint {
@UriParam
private final HdfsConfiguration config;