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 2022/10/28 08:28:03 UTC
[camel] 01/03: Upgrade Pulsar to version 2.10.2
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit eab0922607ccc1621920164d6c860e079f281a0e
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Oct 28 09:21:49 2022 +0200
Upgrade Pulsar to version 2.10.2
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../camel/component/aws2/sqs/Sqs2ConsumerHealthCheck.java | 10 ++++++----
parent/pom.xml | 2 +-
2 files changed, 7 insertions(+), 5 deletions(-)
diff --git a/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2ConsumerHealthCheck.java b/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2ConsumerHealthCheck.java
index dbbc50cc7db..29b6650076c 100644
--- a/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2ConsumerHealthCheck.java
+++ b/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2ConsumerHealthCheck.java
@@ -50,10 +50,12 @@ public class Sqs2ConsumerHealthCheck extends AbstractHealthCheck {
try {
Sqs2Configuration configuration = sqs2Consumer.getConfiguration();
- if (!SqsClient.serviceMetadata().regions().contains(Region.of(configuration.getRegion()))) {
- builder.message("The service is not supported in this region");
- builder.down();
- return;
+ if (ObjectHelper.isNotEmpty(configuration.getRegion())) {
+ if (!SqsClient.serviceMetadata().regions().contains(Region.of(configuration.getRegion()))) {
+ builder.message("The service is not supported in this region");
+ builder.down();
+ return;
+ }
}
SqsClient client;
if (!configuration.isUseDefaultCredentialsProvider()) {
diff --git a/parent/pom.xml b/parent/pom.xml
index fad0d52db30..b5e4dcd90d4 100644
--- a/parent/pom.xml
+++ b/parent/pom.xml
@@ -445,7 +445,7 @@
<protostream-version>4.5.0.Final</protostream-version>
<prowide-version>SRU2022-9.3.2</prowide-version>
<pubnub-version>4.25.0</pubnub-version>
- <pulsar-version>2.10.1</pulsar-version>
+ <pulsar-version>2.10.2</pulsar-version>
<qpid-broker-version>8.0.6</qpid-broker-version>
<qpid-proton-j-version>0.34.0</qpid-proton-j-version>
<qpid-jms-client-version>1.7.0</qpid-jms-client-version>