camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject [3/3] camel git commit: Polished. Fixes #910.
Date Mon, 21 Mar 2016 08:15:11 GMT
Polished. Fixes #910.


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/5207d820
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/5207d820
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/5207d820

Branch: refs/heads/master
Commit: 5207d8205f93a09cfca02092060eabd88b23d0a6
Parents: af9fe4c
Author: Claus Ibsen <davsclaus@apache.org>
Authored: Mon Mar 21 09:14:46 2016 +0100
Committer: Claus Ibsen <davsclaus@apache.org>
Committed: Mon Mar 21 09:14:46 2016 +0100

----------------------------------------------------------------------
 .../component/kafka/KafkaConfiguration.java     | 14 ++++++++++++++
 .../camel/component/kafka/KafkaEndpoint.java    | 20 ++++++++------------
 2 files changed, 22 insertions(+), 12 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/5207d820/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
----------------------------------------------------------------------
diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
index 4a948c1..c110a9d 100644
--- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
+++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
@@ -89,6 +89,8 @@ public class KafkaConfiguration {
     //fetch.max.wait.ms
     @UriParam(label = "consumer", defaultValue = "500")
     private Integer fetchWaitMaxMs = 500;
+    @UriParam(label = "consumer")
+    private boolean seekToBeginning;
 
     //Consumer configuration properties
     @UriParam(label = "consumer")
@@ -1197,4 +1199,16 @@ public class KafkaConfiguration {
         this.valueDeserializer = valueDeserializer;
     }
 
+    public boolean isSeekToBeginning() {
+        return seekToBeginning;
+    }
+
+    /**
+     * If the option is true, then KafkaConsumer will read from beginning on startup.
+     */
+    public void setSeekToBeginning(boolean seekToBeginning) {
+        this.seekToBeginning = seekToBeginning;
+    }
+
+
 }

http://git-wip-us.apache.org/repos/asf/camel/blob/5207d820/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaEndpoint.java
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaEndpoint.java
index 3db41e6..327ecdc 100644
--- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaEndpoint.java
+++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaEndpoint.java
@@ -40,8 +40,6 @@ public class KafkaEndpoint extends DefaultEndpoint implements MultipleConsumersS
     private KafkaConfiguration configuration = new KafkaConfiguration();
     @UriParam
     private boolean bridgeEndpoint;
-    @UriParam
-    private boolean seekToBeginning;
 
     public KafkaEndpoint() {
     }
@@ -665,6 +663,14 @@ public class KafkaEndpoint extends DefaultEndpoint implements MultipleConsumersS
         return configuration.getSslProtocol();
     }
 
+    public boolean isSeekToBeginning() {
+        return configuration.isSeekToBeginning();
+    }
+
+    public void setSeekToBeginning(boolean seekToBeginning) {
+        configuration.setSeekToBeginning(seekToBeginning);
+    }
+
     public boolean isBridgeEndpoint() {
         return bridgeEndpoint;
     }
@@ -676,14 +682,4 @@ public class KafkaEndpoint extends DefaultEndpoint implements MultipleConsumersS
         this.bridgeEndpoint = bridgeEndpoint;
     }
 
-    public boolean isSeekToBeginning() {
-        return seekToBeginning;
-    }
-
-    /**
-     * If the option is true, then KafkaConsumer will read from beginning on startup.
-     */
-    public void setSeekToBeginning(boolean seekToBeginning) {
-        this.seekToBeginning = seekToBeginning;
-    }
 }


Mime
View raw message