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:46 UTC
[camel] branch camel-2.21.x updated (d8141a9 -> d168053)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch camel-2.21.x
in repository https://gitbox.apache.org/repos/asf/camel.git.
from d8141a9 [CAMEL-12364]ensure a SOAP 1.2 enabled camel-cxf consumer endpoint can handle SOAP 1.1 request correctly
new cdd754a CAMEL-12379 - Shutdown only AWS clients owned by the context - AWS S3
new 2887b1b CAMEL-12379 - Shutdown only AWS clients owned by the context - AWS CW
new d5b83d4 CAMEL-12379 - Shutdown only AWS clients owned by the context - AWS DDB
new d68c9da CAMEL-12379 - Shutdown only AWS clients owned by the context - AWS DDB Stream
new 75517c8 CAMEL-12379 - Shutdown only AWS clients owned by the context - AWS EC2
new 57e4fc0 CAMEL-12379 - Shutdown only AWS clients owned by the context - AWS Kinesis Firehose
new 36f1343 CAMEL-12379 - Shutdown only AWS clients owned by the context - AWS Kinesis
new 4b09a10 CAMEL-12379 - Shutdown only AWS clients owned by the context - AWS KMS
new 5478d15 CAMEL-12379 - Shutdown only AWS clients owned by the context - AWS Lambda
new 84c1396 CAMEL-12379 - Shutdown only AWS clients owned by the context - AWS MQ
new a3d28f2 CAMEL-12379 - Shutdown only AWS clients owned by the context - AWS SES
new 2125c1c CAMEL-12379 - Shutdown only AWS clients owned by the context - AWS SNS
new 54ab03a CAMEL-12379 - Shutdown only AWS clients owned by the context - AWS SQS
new d168053 CAMEL-12379 - Shutdown only AWS clients owned by the context - AWS SW
The 14 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../main/java/org/apache/camel/component/aws/cw/CwEndpoint.java | 6 ++++--
.../main/java/org/apache/camel/component/aws/ddb/DdbEndpoint.java | 6 ++++--
.../apache/camel/component/aws/ddbstream/DdbStreamEndpoint.java | 6 ++++--
.../main/java/org/apache/camel/component/aws/ec2/EC2Endpoint.java | 6 ++++--
.../camel/component/aws/firehose/KinesisFirehoseEndpoint.java | 6 ++++--
.../org/apache/camel/component/aws/kinesis/KinesisEndpoint.java | 6 ++++--
.../main/java/org/apache/camel/component/aws/kms/KMSEndpoint.java | 6 ++++--
.../org/apache/camel/component/aws/lambda/LambdaEndpoint.java | 6 ++++--
.../main/java/org/apache/camel/component/aws/mq/MQEndpoint.java | 6 ++++--
.../main/java/org/apache/camel/component/aws/s3/S3Endpoint.java | 7 +++++--
.../main/java/org/apache/camel/component/aws/ses/SesEndpoint.java | 6 ++++--
.../main/java/org/apache/camel/component/aws/sns/SnsEndpoint.java | 6 ++++--
.../main/java/org/apache/camel/component/aws/sqs/SqsEndpoint.java | 7 ++++---
.../main/java/org/apache/camel/component/aws/swf/SWFEndpoint.java | 8 +++++---
14 files changed, 58 insertions(+), 30 deletions(-)
--
To stop receiving notification emails like this one, please contact
acosentino@apache.org.
[camel] 02/14: CAMEL-12379 - Shutdown only AWS clients owned by the
context - AWS CW
Posted by ac...@apache.org.
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 2887b1b87927a47eeb56b510b0eaf145162aa9b8
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Mar 20 07:56:25 2018 +0100
CAMEL-12379 - Shutdown only AWS clients owned by the context - AWS CW
---
.../src/main/java/org/apache/camel/component/aws/cw/CwEndpoint.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/components/camel-aws/src/main/java/org/apache/camel/component/aws/cw/CwEndpoint.java b/components/camel-aws/src/main/java/org/apache/camel/component/aws/cw/CwEndpoint.java
index fa016ff..0a3400a 100644
--- a/components/camel-aws/src/main/java/org/apache/camel/component/aws/cw/CwEndpoint.java
+++ b/components/camel-aws/src/main/java/org/apache/camel/component/aws/cw/CwEndpoint.java
@@ -77,8 +77,10 @@ public class CwEndpoint extends DefaultEndpoint {
@Override
public void doStop() throws Exception {
- if (cloudWatchClient != null) {
- cloudWatchClient.shutdown();
+ if (ObjectHelper.isEmpty(configuration.getAmazonCwClient())) {
+ if (cloudWatchClient != null) {
+ cloudWatchClient.shutdown();
+ }
}
super.doStop();
}
--
To stop receiving notification emails like this one, please contact
acosentino@apache.org.
[camel] 05/14: CAMEL-12379 - Shutdown only AWS clients owned by the
context - AWS EC2
Posted by ac...@apache.org.
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 75517c848a15f8031a62fb4032be0f62ee69a901
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Mar 20 08:03:31 2018 +0100
CAMEL-12379 - Shutdown only AWS clients owned by the context - AWS EC2
---
.../main/java/org/apache/camel/component/aws/ec2/EC2Endpoint.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/components/camel-aws/src/main/java/org/apache/camel/component/aws/ec2/EC2Endpoint.java b/components/camel-aws/src/main/java/org/apache/camel/component/aws/ec2/EC2Endpoint.java
index 0b440c5..77c4ea3 100644
--- a/components/camel-aws/src/main/java/org/apache/camel/component/aws/ec2/EC2Endpoint.java
+++ b/components/camel-aws/src/main/java/org/apache/camel/component/aws/ec2/EC2Endpoint.java
@@ -72,8 +72,10 @@ public class EC2Endpoint extends ScheduledPollEndpoint {
@Override
public void doStop() throws Exception {
- if (ec2Client != null) {
- ec2Client.shutdown();
+ if (ObjectHelper.isEmpty(configuration.getAmazonEc2Client())) {
+ if (ec2Client != null) {
+ ec2Client.shutdown();
+ }
}
super.doStop();
}
--
To stop receiving notification emails like this one, please contact
acosentino@apache.org.
[camel] 11/14: CAMEL-12379 - Shutdown only AWS clients owned by the
context - AWS SES
Posted by ac...@apache.org.
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 a3d28f2961cf59d26c84c51a4cbf3fa4aad1e4b8
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Mar 20 08:09:29 2018 +0100
CAMEL-12379 - Shutdown only AWS clients owned by the context - AWS SES
---
.../main/java/org/apache/camel/component/aws/ses/SesEndpoint.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/components/camel-aws/src/main/java/org/apache/camel/component/aws/ses/SesEndpoint.java b/components/camel-aws/src/main/java/org/apache/camel/component/aws/ses/SesEndpoint.java
index d071d7e..b12cba7 100644
--- a/components/camel-aws/src/main/java/org/apache/camel/component/aws/ses/SesEndpoint.java
+++ b/components/camel-aws/src/main/java/org/apache/camel/component/aws/ses/SesEndpoint.java
@@ -66,8 +66,10 @@ public class SesEndpoint extends DefaultEndpoint {
@Override
public void doStop() throws Exception {
- if (sesClient != null) {
- sesClient.shutdown();
+ if (ObjectHelper.isEmpty(configuration.getAmazonSESClient())) {
+ if (sesClient != null) {
+ sesClient.shutdown();
+ }
}
super.doStop();
}
--
To stop receiving notification emails like this one, please contact
acosentino@apache.org.
[camel] 03/14: CAMEL-12379 - Shutdown only AWS clients owned by the
context - AWS DDB
Posted by ac...@apache.org.
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 d5b83d425a3c7cecb8b8bd40bdaa1a3bc7876246
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Mar 20 08:01:52 2018 +0100
CAMEL-12379 - Shutdown only AWS clients owned by the context - AWS DDB
---
.../main/java/org/apache/camel/component/aws/ddb/DdbEndpoint.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/components/camel-aws/src/main/java/org/apache/camel/component/aws/ddb/DdbEndpoint.java b/components/camel-aws/src/main/java/org/apache/camel/component/aws/ddb/DdbEndpoint.java
index fa8f45e..0daea42 100644
--- a/components/camel-aws/src/main/java/org/apache/camel/component/aws/ddb/DdbEndpoint.java
+++ b/components/camel-aws/src/main/java/org/apache/camel/component/aws/ddb/DdbEndpoint.java
@@ -114,8 +114,10 @@ public class DdbEndpoint extends ScheduledPollEndpoint {
@Override
public void doStop() throws Exception {
- if (ddbClient != null) {
- ddbClient.shutdown();
+ if (ObjectHelper.isEmpty(configuration.getAmazonDDBClient())) {
+ if (ddbClient != null) {
+ ddbClient.shutdown();
+ }
}
super.doStop();
}
--
To stop receiving notification emails like this one, please contact
acosentino@apache.org.
[camel] 10/14: CAMEL-12379 - Shutdown only AWS clients owned by the
context - AWS MQ
Posted by ac...@apache.org.
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 84c13962978162435ec584bf2f3a9ab5c3ac4e25
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Mar 20 08:07:57 2018 +0100
CAMEL-12379 - Shutdown only AWS clients owned by the context - AWS MQ
---
.../src/main/java/org/apache/camel/component/aws/mq/MQEndpoint.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/components/camel-aws/src/main/java/org/apache/camel/component/aws/mq/MQEndpoint.java b/components/camel-aws/src/main/java/org/apache/camel/component/aws/mq/MQEndpoint.java
index cb44848..3322231 100644
--- a/components/camel-aws/src/main/java/org/apache/camel/component/aws/mq/MQEndpoint.java
+++ b/components/camel-aws/src/main/java/org/apache/camel/component/aws/mq/MQEndpoint.java
@@ -71,8 +71,10 @@ public class MQEndpoint extends ScheduledPollEndpoint {
@Override
public void doStop() throws Exception {
- if (mqClient != null) {
- mqClient.shutdown();
+ if (ObjectHelper.isEmpty(configuration.getAmazonMqClient())) {
+ if (mqClient != null) {
+ mqClient.shutdown();
+ }
}
super.doStop();
}
--
To stop receiving notification emails like this one, please contact
acosentino@apache.org.
[camel] 08/14: CAMEL-12379 - Shutdown only AWS clients owned by the
context - AWS KMS
Posted by ac...@apache.org.
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 4b09a105a818c7b71f4817e20e18b53ce8017c25
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Mar 20 08:06:29 2018 +0100
CAMEL-12379 - Shutdown only AWS clients owned by the context - AWS KMS
---
.../main/java/org/apache/camel/component/aws/kms/KMSEndpoint.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/components/camel-aws/src/main/java/org/apache/camel/component/aws/kms/KMSEndpoint.java b/components/camel-aws/src/main/java/org/apache/camel/component/aws/kms/KMSEndpoint.java
index 2d6a61f..4a5f15d 100644
--- a/components/camel-aws/src/main/java/org/apache/camel/component/aws/kms/KMSEndpoint.java
+++ b/components/camel-aws/src/main/java/org/apache/camel/component/aws/kms/KMSEndpoint.java
@@ -70,8 +70,10 @@ public class KMSEndpoint extends ScheduledPollEndpoint {
@Override
public void doStop() throws Exception {
- if (kmsClient != null) {
- kmsClient.shutdown();
+ if (ObjectHelper.isEmpty(configuration.getKmsClient())) {
+ if (kmsClient != null) {
+ kmsClient.shutdown();
+ }
}
super.doStop();
}
--
To stop receiving notification emails like this one, please contact
acosentino@apache.org.
[camel] 07/14: CAMEL-12379 - Shutdown only AWS clients owned by the
context - AWS Kinesis
Posted by ac...@apache.org.
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 36f1343cb1d5afb0aeb43772a2a99103bbc2e4d4
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Mar 20 08:05:44 2018 +0100
CAMEL-12379 - Shutdown only AWS clients owned by the context - AWS Kinesis
---
.../org/apache/camel/component/aws/kinesis/KinesisEndpoint.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
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 6e12682..9ec98e2 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
@@ -67,8 +67,10 @@ public class KinesisEndpoint extends ScheduledPollEndpoint {
@Override
public void doStop() throws Exception {
- if (kinesisClient != null) {
- kinesisClient.shutdown();
+ if (ObjectHelper.isEmpty(configuration.getAmazonKinesisClient())) {
+ if (kinesisClient != null) {
+ kinesisClient.shutdown();
+ }
}
super.doStop();
}
--
To stop receiving notification emails like this one, please contact
acosentino@apache.org.
[camel] 01/14: CAMEL-12379 - Shutdown only AWS clients owned by the
context - AWS S3
Posted by ac...@apache.org.
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 cdd754a7819d28828aafb820b05385f8e06bc336
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Mar 20 07:53:12 2018 +0100
CAMEL-12379 - Shutdown only AWS clients owned by the context - AWS S3
---
.../main/java/org/apache/camel/component/aws/s3/S3Endpoint.java | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
diff --git a/components/camel-aws/src/main/java/org/apache/camel/component/aws/s3/S3Endpoint.java b/components/camel-aws/src/main/java/org/apache/camel/component/aws/s3/S3Endpoint.java
index 76ce195..d6a2ffe 100644
--- a/components/camel-aws/src/main/java/org/apache/camel/component/aws/s3/S3Endpoint.java
+++ b/components/camel-aws/src/main/java/org/apache/camel/component/aws/s3/S3Endpoint.java
@@ -38,6 +38,7 @@ import org.apache.camel.spi.UriParam;
import org.apache.camel.spi.UriPath;
import org.apache.camel.support.SynchronizationAdapter;
import org.apache.camel.util.IOHelper;
+import org.apache.camel.util.ObjectHelper;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -140,8 +141,10 @@ public class S3Endpoint extends ScheduledPollEndpoint {
@Override
public void doStop() throws Exception {
- if (s3Client != null) {
- s3Client.shutdown();
+ if (ObjectHelper.isEmpty(configuration.getAmazonS3Client())) {
+ if (s3Client != null) {
+ s3Client.shutdown();
+ }
}
super.doStop();
}
--
To stop receiving notification emails like this one, please contact
acosentino@apache.org.
[camel] 14/14: CAMEL-12379 - Shutdown only AWS clients owned by the
context - AWS SW
Posted by ac...@apache.org.
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 d168053d863be33c155854f9fcb590a9cacb3e5d
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Mar 20 08:11:58 2018 +0100
CAMEL-12379 - Shutdown only AWS clients owned by the context - AWS SW
---
.../main/java/org/apache/camel/component/aws/swf/SWFEndpoint.java | 8 +++++---
1 file changed, 5 insertions(+), 3 deletions(-)
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 238adfe..8be1908 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
@@ -84,9 +84,11 @@ public class SWFEndpoint extends DefaultEndpoint {
@Override
protected void doStop() throws Exception {
- if (amazonSWClient != null) {
- amazonSWClient.shutdown();
- amazonSWClient = null;
+ if (ObjectHelper.isEmpty(configuration.getAmazonSWClient())) {
+ if (amazonSWClient != null) {
+ amazonSWClient.shutdown();
+ amazonSWClient = null;
+ }
}
super.doStop();
}
--
To stop receiving notification emails like this one, please contact
acosentino@apache.org.
[camel] 13/14: CAMEL-12379 - Shutdown only AWS clients owned by the
context - AWS SQS
Posted by ac...@apache.org.
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 54ab03a7b49df6c10ee7db91d1a6840a588625f6
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Mar 20 08:11:03 2018 +0100
CAMEL-12379 - Shutdown only AWS clients owned by the context - AWS SQS
---
.../main/java/org/apache/camel/component/aws/sqs/SqsEndpoint.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git a/components/camel-aws/src/main/java/org/apache/camel/component/aws/sqs/SqsEndpoint.java b/components/camel-aws/src/main/java/org/apache/camel/component/aws/sqs/SqsEndpoint.java
index fda087e..1ab049b 100644
--- a/components/camel-aws/src/main/java/org/apache/camel/component/aws/sqs/SqsEndpoint.java
+++ b/components/camel-aws/src/main/java/org/apache/camel/component/aws/sqs/SqsEndpoint.java
@@ -24,7 +24,6 @@ import com.amazonaws.auth.AWSCredentials;
import com.amazonaws.auth.AWSCredentialsProvider;
import com.amazonaws.auth.AWSStaticCredentialsProvider;
import com.amazonaws.auth.BasicAWSCredentials;
-import com.amazonaws.client.builder.AwsClientBuilder.EndpointConfiguration;
import com.amazonaws.regions.Regions;
import com.amazonaws.services.sqs.AmazonSQS;
import com.amazonaws.services.sqs.AmazonSQSClientBuilder;
@@ -221,8 +220,10 @@ public class SqsEndpoint extends ScheduledPollEndpoint implements HeaderFilterSt
@Override
public void doStop() throws Exception {
- if (client != null) {
- client.shutdown();
+ if (ObjectHelper.isEmpty(configuration.getAmazonSQSClient())) {
+ if (client != null) {
+ client.shutdown();
+ }
}
super.doStop();
}
--
To stop receiving notification emails like this one, please contact
acosentino@apache.org.
[camel] 06/14: CAMEL-12379 - Shutdown only AWS clients owned by the
context - AWS Kinesis Firehose
Posted by ac...@apache.org.
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 57e4fc05fbb338edf0c4cc8077cc947985d9c164
Author: Andrea Cosentino <an...@gmail.com>
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
acosentino@apache.org.
[camel] 04/14: CAMEL-12379 - Shutdown only AWS clients owned by the
context - AWS DDB Stream
Posted by ac...@apache.org.
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.
[camel] 12/14: CAMEL-12379 - Shutdown only AWS clients owned by the
context - AWS SNS
Posted by ac...@apache.org.
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 2125c1c00a2d2a9a06f78ce6da632a9da5b1cf8e
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Mar 20 08:10:10 2018 +0100
CAMEL-12379 - Shutdown only AWS clients owned by the context - AWS SNS
---
.../main/java/org/apache/camel/component/aws/sns/SnsEndpoint.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/components/camel-aws/src/main/java/org/apache/camel/component/aws/sns/SnsEndpoint.java b/components/camel-aws/src/main/java/org/apache/camel/component/aws/sns/SnsEndpoint.java
index 0576914..ad89d46 100644
--- a/components/camel-aws/src/main/java/org/apache/camel/component/aws/sns/SnsEndpoint.java
+++ b/components/camel-aws/src/main/java/org/apache/camel/component/aws/sns/SnsEndpoint.java
@@ -155,8 +155,10 @@ public class SnsEndpoint extends DefaultEndpoint implements HeaderFilterStrategy
@Override
public void doStop() throws Exception {
- if (snsClient != null) {
- snsClient.shutdown();
+ if (ObjectHelper.isEmpty(configuration.getAmazonSNSClient())) {
+ if (snsClient != null) {
+ snsClient.shutdown();
+ }
}
super.doStop();
}
--
To stop receiving notification emails like this one, please contact
acosentino@apache.org.
[camel] 09/14: CAMEL-12379 - Shutdown only AWS clients owned by the
context - AWS Lambda
Posted by ac...@apache.org.
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 5478d1553e1ccffae0da8e1df6acae94d111649c
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Mar 20 08:07:12 2018 +0100
CAMEL-12379 - Shutdown only AWS clients owned by the context - AWS Lambda
---
.../java/org/apache/camel/component/aws/lambda/LambdaEndpoint.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/components/camel-aws/src/main/java/org/apache/camel/component/aws/lambda/LambdaEndpoint.java b/components/camel-aws/src/main/java/org/apache/camel/component/aws/lambda/LambdaEndpoint.java
index 5d57793..b83ffd9 100644
--- a/components/camel-aws/src/main/java/org/apache/camel/component/aws/lambda/LambdaEndpoint.java
+++ b/components/camel-aws/src/main/java/org/apache/camel/component/aws/lambda/LambdaEndpoint.java
@@ -69,8 +69,10 @@ public class LambdaEndpoint extends DefaultEndpoint {
@Override
public void doStop() throws Exception {
- if (awsLambdaClient != null) {
- awsLambdaClient.shutdown();
+ if (ObjectHelper.isEmpty(configuration.getAwsLambdaClient())) {
+ if (awsLambdaClient != null) {
+ awsLambdaClient.shutdown();
+ }
}
super.doStop();
}
--
To stop receiving notification emails like this one, please contact
acosentino@apache.org.