camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject camel git commit: Copy the scheduler properties to the consumer from the endpoint so that they get applied.
Date Wed, 16 Dec 2015 13:17:18 GMT
Repository: camel
Updated Branches:
  refs/heads/master 83eca0b3f -> 3da84a6ba


Copy the scheduler properties to the consumer from the endpoint so that they get applied.


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

Branch: refs/heads/master
Commit: 3da84a6baae4d1cdc6a3344598deb1ed032d957e
Parents: 83eca0b
Author: Candle <candle@candle.me.uk>
Authored: Mon Dec 7 09:31:43 2015 +0000
Committer: Claus Ibsen <davsclaus@apache.org>
Committed: Wed Dec 16 14:17:09 2015 +0100

----------------------------------------------------------------------
 .../org/apache/camel/component/aws/kinesis/KinesisEndpoint.java  | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/3da84a6b/components/camel-aws/src/main/java/org/apache/camel/component/aws/kinesis/KinesisEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-aws/src/main/java/org/apache/camel/component/aws/kinesis/KinesisEndpoint.java
b/components/camel-aws/src/main/java/org/apache/camel/component/aws/kinesis/KinesisEndpoint.java
index 5a8b1cd..b041a85 100644
--- a/components/camel-aws/src/main/java/org/apache/camel/component/aws/kinesis/KinesisEndpoint.java
+++ b/components/camel-aws/src/main/java/org/apache/camel/component/aws/kinesis/KinesisEndpoint.java
@@ -59,7 +59,9 @@ public class KinesisEndpoint extends ScheduledPollEndpoint {
 
     @Override
     public Consumer createConsumer(Processor processor) throws Exception {
-        return new KinesisConsumer(this, processor);
+        final KinesisConsumer consumer = new KinesisConsumer(this, processor);
+        consumer.setSchedulerProperties(getSchedulerProperties());
+        return consumer;
     }
 
     public Exchange createExchange(Record record) {


Mime
View raw message