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 2015/12/16 14:17:18 UTC
camel git commit: Copy the scheduler properties to the consumer from
the endpoint so that they get applied.
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 <ca...@candle.me.uk>
Authored: Mon Dec 7 09:31:43 2015 +0000
Committer: Claus Ibsen <da...@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) {