Repository: camel Updated Branches: refs/heads/camel-2.16.x 2451f0636 -> 2200e51df refs/heads/master 30b298435 -> 9204ccf9c
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/a061340f Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/a061340f Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/a061340f Branch: refs/heads/master Commit: a061340f9e7b77fddc73ed5f4168acaaa56b94a0 Parents: 30b2984 Author: Claus Ibsen <davscl...@apache.org> Authored: Sat Jan 16 12:23:58 2016 +0100 Committer: Claus Ibsen <davscl...@apache.org> Committed: Sat Jan 16 12:23:58 2016 +0100 ---------------------------------------------------------------------- .../main/java/org/apache/camel/component/hdfs2/HdfsEndpoint.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/a061340f/components/camel-hdfs2/src/main/java/org/apache/camel/component/hdfs2/HdfsEndpoint.java ---------------------------------------------------------------------- diff --git a/components/camel-hdfs2/src/main/java/org/apache/camel/component/hdfs2/HdfsEndpoint.java b/components/camel-hdfs2/src/main/java/org/apache/camel/component/hdfs2/HdfsEndpoint.java index 8bae293..baecdcc 100644 --- a/components/camel-hdfs2/src/main/java/org/apache/camel/component/hdfs2/HdfsEndpoint.java +++ b/components/camel-hdfs2/src/main/java/org/apache/camel/component/hdfs2/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 2.x. */ @UriEndpoint(scheme = "hdfs2", title = "HDFS2", syntax = "hdfs2:hostName:port/path", consumerClass = HdfsConsumer.class, label = "hadoop,file") -public class HdfsEndpoint extends DefaultEndpoint { +public class HdfsEndpoint extends ScheduledPollEndpoint { @UriParam private final HdfsConfiguration config;
