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 be5d7b0b9b1b414800950250fe929cf5f6298bf1 Author: Andrea Cosentino <[email protected]> AuthorDate: Tue Mar 20 08:04:20 2018 +0100 CAMEL-12379 - Shutdown only AWS clients owned by the context - AWS Kinesis Firehose --- .../camel/component/aws/firehose/KinesisFirehoseEndpoint.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/components/camel-aws/src/main/java/org/apache/camel/component/aws/firehose/KinesisFirehoseEndpoint.java b/components/camel-aws/src/main/java/org/apache/camel/component/aws/firehose/KinesisFirehoseEndpoint.java index 7bed819..3dbca8e 100644 --- a/components/camel-aws/src/main/java/org/apache/camel/component/aws/firehose/KinesisFirehoseEndpoint.java +++ b/components/camel-aws/src/main/java/org/apache/camel/component/aws/firehose/KinesisFirehoseEndpoint.java @@ -69,8 +69,10 @@ public class KinesisFirehoseEndpoint extends DefaultEndpoint { @Override public void doStop() throws Exception { - if (kinesisFirehoseClient != null) { - kinesisFirehoseClient.shutdown(); + if (ObjectHelper.isEmpty(configuration.getAmazonKinesisFirehoseClient())) { + if (kinesisFirehoseClient != null) { + kinesisFirehoseClient.shutdown(); + } } super.doStop(); } -- To stop receiving notification emails like this one, please contact [email protected].
