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 <can...@candle.me.uk> Authored: Mon Dec 7 09:31:43 2015 +0000 Committer: Claus Ibsen <davscl...@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) {
