camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject [7/8] camel git commit: camel-hdfs - should extend poll endpoint as the consumer is poll based.
Date Sat, 16 Jan 2016 11:40:23 GMT
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/a0757e03
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/a0757e03
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/a0757e03

Branch: refs/heads/camel-2.16.x
Commit: a0757e03488af4aeb2ef2b3d82ac8ae254d0b12e
Parents: 01aa3fd
Author: Claus Ibsen <davsclaus@apache.org>
Authored: Sat Jan 16 12:33:20 2016 +0100
Committer: Claus Ibsen <davsclaus@apache.org>
Committed: Sat Jan 16 12:39:57 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/a0757e03/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 0aeb4a9..5d63ed7 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,12 +23,12 @@ 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;
 
 @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;


Mime
View raw message