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 2016/01/19 11:46:21 UTC
camel git commit: CAMEL-9520: Make sure to configure consumer
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 <da...@apache.org>
Authored: Tue Jan 19 11:42:29 2016 +0100
Committer: Claus Ibsen <da...@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() {