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/03/20 07:15:50 UTC

[camel] 04/14: CAMEL-12379 - Shutdown only AWS clients owned by the context - AWS DDB Stream

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

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

commit d68c9da938c51117366d912e1c90512c779e2954
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Mar 20 08:02:38 2018 +0100

    CAMEL-12379 - Shutdown only AWS clients owned by the context - AWS DDB Stream
---
 .../org/apache/camel/component/aws/ddbstream/DdbStreamEndpoint.java | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

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 662c8ec..11e12fa 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
@@ -82,8 +82,10 @@ public class DdbStreamEndpoint extends ScheduledPollEndpoint {
     
     @Override
     public void doStop() throws Exception {
-        if (ddbStreamClient != null) {
-            ddbStreamClient.shutdown();
+        if (ObjectHelper.isEmpty(configuration.getAmazonDynamoDbStreamsClient())) {
+            if (ddbStreamClient != null) {
+                ddbStreamClient.shutdown();
+            }
         }
         super.doStop();
     }

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