Repository: camel Updated Branches: refs/heads/master dfe89f6ff -> 31d91911a
CAMEL-9520: Make sure to configure consumer Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/31d91911 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/31d91911 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/31d91911 Branch: refs/heads/master Commit: 31d91911a50985b22b86528d2091cdfdce2b4cfa Parents: dfe89f6 Author: Claus Ibsen <davscl...@apache.org> Authored: Tue Jan 19 11:42:29 2016 +0100 Committer: Claus Ibsen <davscl...@apache.org> Committed: Tue Jan 19 11:44:10 2016 +0100 ---------------------------------------------------------------------- .../apache/camel/component/aws/ddbstream/DdbStreamEndpoint.java | 1 + .../org/apache/camel/component/aws/kinesis/KinesisEndpoint.java | 1 + .../java/org/apache/camel/component/aws/swf/SWFEndpoint.java | 4 +++- 3 files changed, 5 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/31d91911/components/camel-aws/src/main/java/org/apache/camel/component/aws/ddbstream/DdbStreamEndpoint.java ---------------------------------------------------------------------- diff --git a/components/camel-aws/src/main/java/org/apache/camel/component/aws/ddbstream/DdbStreamEndpoint.java b/components/camel-aws/src/main/java/org/apache/camel/component/aws/ddbstream/DdbStreamEndpoint.java index 383f272..b64ac9b 100644 --- a/components/camel-aws/src/main/java/org/apache/camel/component/aws/ddbstream/DdbStreamEndpoint.java +++ b/components/camel-aws/src/main/java/org/apache/camel/component/aws/ddbstream/DdbStreamEndpoint.java @@ -84,6 +84,7 @@ public class DdbStreamEndpoint extends ScheduledPollEndpoint { public Consumer createConsumer(Processor processor) throws Exception { DdbStreamConsumer consumer = new DdbStreamConsumer(this, processor); consumer.setSchedulerProperties(consumer.getEndpoint().getSchedulerProperties()); + configureConsumer(consumer); return consumer; } http://git-wip-us.apache.org/repos/asf/camel/blob/31d91911/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 b3ce926..befcbaa 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 @@ -64,6 +64,7 @@ public class KinesisEndpoint extends ScheduledPollEndpoint { public Consumer createConsumer(Processor processor) throws Exception { final KinesisConsumer consumer = new KinesisConsumer(this, processor); consumer.setSchedulerProperties(getSchedulerProperties()); + configureConsumer(consumer); return consumer; } http://git-wip-us.apache.org/repos/asf/camel/blob/31d91911/components/camel-aws/src/main/java/org/apache/camel/component/aws/swf/SWFEndpoint.java ---------------------------------------------------------------------- diff --git a/components/camel-aws/src/main/java/org/apache/camel/component/aws/swf/SWFEndpoint.java b/components/camel-aws/src/main/java/org/apache/camel/component/aws/swf/SWFEndpoint.java index 16d543c..9907045 100644 --- a/components/camel-aws/src/main/java/org/apache/camel/component/aws/swf/SWFEndpoint.java +++ b/components/camel-aws/src/main/java/org/apache/camel/component/aws/swf/SWFEndpoint.java @@ -57,8 +57,10 @@ public class SWFEndpoint extends DefaultEndpoint { } public Consumer createConsumer(Processor processor) throws Exception { - return isWorkflow() + Consumer consumer = isWorkflow() ? new SWFWorkflowConsumer(this, processor, configuration) : new SWFActivityConsumer(this, processor, configuration); + configureConsumer(consumer); + return consumer; } public boolean isSingleton() {
