You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2018/01/22 10:54:43 UTC

[camel] 02/03: Camel-AWS - Let set properties on endpoint too

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 06829cd83f81e6c25e2416edbc777b1e51b9f423
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Mon Jan 22 10:18:10 2018 +0100

    Camel-AWS - Let set properties on endpoint too
---
 .../org/apache/camel/component/aws/ddbstream/DdbStreamComponent.java     | 1 +
 .../java/org/apache/camel/component/aws/kinesis/KinesisComponent.java    | 1 +
 2 files changed, 2 insertions(+)

diff --git a/components/camel-aws/src/main/java/org/apache/camel/component/aws/ddbstream/DdbStreamComponent.java b/components/camel-aws/src/main/java/org/apache/camel/component/aws/ddbstream/DdbStreamComponent.java
index ca16663..46d4a44 100644
--- a/components/camel-aws/src/main/java/org/apache/camel/component/aws/ddbstream/DdbStreamComponent.java
+++ b/components/camel-aws/src/main/java/org/apache/camel/component/aws/ddbstream/DdbStreamComponent.java
@@ -68,6 +68,7 @@ public class DdbStreamComponent extends DefaultComponent {
         }
         
         DdbStreamEndpoint endpoint = new DdbStreamEndpoint(uri, configuration, this);
+        setProperties(endpoint, parameters);
         return endpoint;
     }
     
diff --git a/components/camel-aws/src/main/java/org/apache/camel/component/aws/kinesis/KinesisComponent.java b/components/camel-aws/src/main/java/org/apache/camel/component/aws/kinesis/KinesisComponent.java
index e1a3385..6eec875 100644
--- a/components/camel-aws/src/main/java/org/apache/camel/component/aws/kinesis/KinesisComponent.java
+++ b/components/camel-aws/src/main/java/org/apache/camel/component/aws/kinesis/KinesisComponent.java
@@ -62,6 +62,7 @@ public class KinesisComponent extends DefaultComponent {
         }
         
         KinesisEndpoint endpoint = new KinesisEndpoint(uri, configuration, this);
+        setProperties(endpoint, parameters);
         return endpoint;
     }
     

-- 
To stop receiving notification emails like this one, please contact
acosentino@apache.org.