Skip to content

Commit

Permalink
Upgrade Camel to 4.0.1
Browse files Browse the repository at this point in the history
  • Loading branch information
jamesnetherton committed Sep 25, 2023
1 parent 268dd87 commit 17290d0
Show file tree
Hide file tree
Showing 44 changed files with 1,056 additions and 1,123 deletions.
2 changes: 1 addition & 1 deletion docs/antora.yml
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ asciidoc:
requires: "'util=camel-website-util,quarkus=xref:js/quarkus.js'"

# Project versions
camel-version: 4.0.0 # replace ${camel.version}
camel-version: 4.0.1 # replace ${camel.version}
camel-docs-version: 4.0.x # replace ${camel.docs.components.version}
quarkus-version: 3.4.1 # replace ${quarkus.version}
graalvm-version: 23.0.1 # replace ${graalvm.version}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,5 +9,5 @@ cqJvmSince: 2.0.0
cqNativeSince: n/a
cqCamelPartName: aws-secrets-manager
cqCamelPartTitle: AWS Secrets Manager
cqCamelPartDescription: Manage AWS Secrets Manager services using AWS SDK version 2.x.
cqCamelPartDescription: Manage secrets using AWS Secrets Manager.
cqExtensionPageTitle: AWS Secrets Manager
2 changes: 1 addition & 1 deletion docs/modules/ROOT/examples/components/aws2-athena.yml
Original file line number Diff line number Diff line change
Expand Up @@ -9,5 +9,5 @@ cqJvmSince: 1.0.0
cqNativeSince: 1.0.0
cqCamelPartName: aws2-athena
cqCamelPartTitle: AWS Athena
cqCamelPartDescription: Access AWS Athena service using AWS SDK version 2.x.
cqCamelPartDescription: Access AWS Athena.
cqExtensionPageTitle: AWS 2 Athena
2 changes: 1 addition & 1 deletion docs/modules/ROOT/examples/components/aws2-cw.yml
Original file line number Diff line number Diff line change
Expand Up @@ -9,5 +9,5 @@ cqJvmSince: 1.0.0
cqNativeSince: 1.0.0
cqCamelPartName: aws2-cw
cqCamelPartTitle: AWS CloudWatch
cqCamelPartDescription: Sending metrics to AWS CloudWatch using AWS SDK version 2.x.
cqCamelPartDescription: Sending metrics to AWS CloudWatch.
cqExtensionPageTitle: AWS 2 CloudWatch
2 changes: 1 addition & 1 deletion docs/modules/ROOT/examples/components/aws2-ddb.yml
Original file line number Diff line number Diff line change
Expand Up @@ -9,5 +9,5 @@ cqJvmSince: 1.0.0
cqNativeSince: 1.0.0
cqCamelPartName: aws2-ddb
cqCamelPartTitle: AWS DynamoDB
cqCamelPartDescription: Store and retrieve data from AWS DynamoDB service using AWS SDK version 2.x.
cqCamelPartDescription: Store and retrieve data from AWS DynamoDB.
cqExtensionPageTitle: AWS 2 DynamoDB
2 changes: 1 addition & 1 deletion docs/modules/ROOT/examples/components/aws2-ddbstream.yml
Original file line number Diff line number Diff line change
Expand Up @@ -9,5 +9,5 @@ cqJvmSince: 1.0.0
cqNativeSince: 1.0.0
cqCamelPartName: aws2-ddbstream
cqCamelPartTitle: AWS DynamoDB Streams
cqCamelPartDescription: Receive messages from AWS DynamoDB Stream service using AWS SDK version 2.x.
cqCamelPartDescription: Receive messages from AWS DynamoDB Stream.
cqExtensionPageTitle: AWS 2 DynamoDB
2 changes: 1 addition & 1 deletion docs/modules/ROOT/examples/components/aws2-ec2.yml
Original file line number Diff line number Diff line change
Expand Up @@ -9,5 +9,5 @@ cqJvmSince: 1.0.0
cqNativeSince: 1.0.0
cqCamelPartName: aws2-ec2
cqCamelPartTitle: AWS Elastic Compute Cloud (EC2)
cqCamelPartDescription: Manage AWS EC2 instances using AWS SDK version 2.x.
cqCamelPartDescription: Manage AWS EC2 instances.
cqExtensionPageTitle: AWS 2 Elastic Compute Cloud (EC2)
2 changes: 1 addition & 1 deletion docs/modules/ROOT/examples/components/aws2-ecs.yml
Original file line number Diff line number Diff line change
Expand Up @@ -9,5 +9,5 @@ cqJvmSince: 1.0.0
cqNativeSince: 1.0.0
cqCamelPartName: aws2-ecs
cqCamelPartTitle: AWS Elastic Container Service (ECS)
cqCamelPartDescription: Manage AWS ECS cluster instances using AWS SDK version 2.x.
cqCamelPartDescription: Manage AWS ECS cluster instances.
cqExtensionPageTitle: AWS 2 Elastic Container Service (ECS)
2 changes: 1 addition & 1 deletion docs/modules/ROOT/examples/components/aws2-eks.yml
Original file line number Diff line number Diff line change
Expand Up @@ -9,5 +9,5 @@ cqJvmSince: 1.0.0
cqNativeSince: 1.0.0
cqCamelPartName: aws2-eks
cqCamelPartTitle: AWS Elastic Kubernetes Service (EKS)
cqCamelPartDescription: Manage AWS EKS cluster instances using AWS SDK version 2.x.
cqCamelPartDescription: Manage AWS EKS cluster instances.
cqExtensionPageTitle: AWS 2 Elastic Kubernetes Service (EKS)
2 changes: 1 addition & 1 deletion docs/modules/ROOT/examples/components/aws2-eventbridge.yml
Original file line number Diff line number Diff line change
Expand Up @@ -9,5 +9,5 @@ cqJvmSince: 1.4.0
cqNativeSince: 1.7.0
cqCamelPartName: aws2-eventbridge
cqCamelPartTitle: AWS Eventbridge
cqCamelPartDescription: Manage AWS Eventbridge cluster instances using AWS SDK version 2.x.
cqCamelPartDescription: Send events to AWS Eventbridge cluster instances.
cqExtensionPageTitle: AWS 2 Eventbridge
2 changes: 1 addition & 1 deletion docs/modules/ROOT/examples/components/aws2-iam.yml
Original file line number Diff line number Diff line change
Expand Up @@ -9,5 +9,5 @@ cqJvmSince: 1.0.0
cqNativeSince: 1.0.0
cqCamelPartName: aws2-iam
cqCamelPartTitle: AWS Identity and Access Management (IAM)
cqCamelPartDescription: Manage AWS IAM instances using AWS SDK version 2.x.
cqCamelPartDescription: Manage AWS IAM instances.
cqExtensionPageTitle: AWS 2 Identity and Access Management (IAM)
Original file line number Diff line number Diff line change
Expand Up @@ -9,5 +9,5 @@ cqJvmSince: 1.1.0
cqNativeSince: 1.7.0
cqCamelPartName: aws2-kinesis-firehose
cqCamelPartTitle: AWS Kinesis Firehose
cqCamelPartDescription: Produce data to AWS Kinesis Firehose streams using AWS SDK version 2.x.
cqCamelPartDescription: Produce data to AWS Kinesis Firehose streams.
cqExtensionPageTitle: AWS 2 Kinesis
2 changes: 1 addition & 1 deletion docs/modules/ROOT/examples/components/aws2-kinesis.yml
Original file line number Diff line number Diff line change
Expand Up @@ -9,5 +9,5 @@ cqJvmSince: 1.1.0
cqNativeSince: 1.7.0
cqCamelPartName: aws2-kinesis
cqCamelPartTitle: AWS Kinesis
cqCamelPartDescription: Consume and produce records from and to AWS Kinesis Streams using AWS SDK version 2.x.
cqCamelPartDescription: Consume and produce records from and to AWS Kinesis Streams.
cqExtensionPageTitle: AWS 2 Kinesis
2 changes: 1 addition & 1 deletion docs/modules/ROOT/examples/components/aws2-kms.yml
Original file line number Diff line number Diff line change
Expand Up @@ -9,5 +9,5 @@ cqJvmSince: 1.0.0
cqNativeSince: 1.0.0
cqCamelPartName: aws2-kms
cqCamelPartTitle: AWS Key Management Service (KMS)
cqCamelPartDescription: Manage keys stored in AWS KMS instances using AWS SDK version 2.x.
cqCamelPartDescription: Manage keys stored in AWS KMS instances.
cqExtensionPageTitle: AWS 2 Key Management Service (KMS)
2 changes: 1 addition & 1 deletion docs/modules/ROOT/examples/components/aws2-lambda.yml
Original file line number Diff line number Diff line change
Expand Up @@ -9,5 +9,5 @@ cqJvmSince: 1.1.0
cqNativeSince: 1.1.0
cqCamelPartName: aws2-lambda
cqCamelPartTitle: AWS Lambda
cqCamelPartDescription: Manage and invoke AWS Lambda functions using AWS SDK version 2.x.
cqCamelPartDescription: Manage and invoke AWS Lambda functions.
cqExtensionPageTitle: AWS 2 Lambda
2 changes: 1 addition & 1 deletion docs/modules/ROOT/examples/components/aws2-mq.yml
Original file line number Diff line number Diff line change
Expand Up @@ -9,5 +9,5 @@ cqJvmSince: 1.0.0
cqNativeSince: 1.0.0
cqCamelPartName: aws2-mq
cqCamelPartTitle: AWS MQ
cqCamelPartDescription: Manage AWS MQ instances using AWS SDK version 2.x.
cqCamelPartDescription: Send messages to AWS MQ.
cqExtensionPageTitle: AWS 2 MQ
2 changes: 1 addition & 1 deletion docs/modules/ROOT/examples/components/aws2-msk.yml
Original file line number Diff line number Diff line change
Expand Up @@ -9,5 +9,5 @@ cqJvmSince: 1.0.0
cqNativeSince: 1.0.0
cqCamelPartName: aws2-msk
cqCamelPartTitle: AWS Managed Streaming for Apache Kafka (MSK)
cqCamelPartDescription: Manage AWS MSK instances using AWS SDK version 2.x.
cqCamelPartDescription: Manage AWS MSK instances.
cqExtensionPageTitle: AWS 2 Managed Streaming for Apache Kafka (MSK)
2 changes: 1 addition & 1 deletion docs/modules/ROOT/examples/components/aws2-s3.yml
Original file line number Diff line number Diff line change
Expand Up @@ -9,5 +9,5 @@ cqJvmSince: 1.0.0
cqNativeSince: 1.0.0
cqCamelPartName: aws2-s3
cqCamelPartTitle: AWS S3 Storage Service
cqCamelPartDescription: Store and retrieve objects from AWS S3 Storage Service using AWS SDK version 2.x.
cqCamelPartDescription: Store and retrieve objects from AWS S3 Storage Service.
cqExtensionPageTitle: AWS 2 S3 Storage Service
2 changes: 1 addition & 1 deletion docs/modules/ROOT/examples/components/aws2-ses.yml
Original file line number Diff line number Diff line change
Expand Up @@ -9,5 +9,5 @@ cqJvmSince: 1.0.0
cqNativeSince: 1.0.0
cqCamelPartName: aws2-ses
cqCamelPartTitle: AWS Simple Email Service (SES)
cqCamelPartDescription: Send e-mails through AWS SES service using AWS SDK version 2.x.
cqCamelPartDescription: Send e-mails through AWS SES service.
cqExtensionPageTitle: AWS 2 Simple Email Service (SES)
2 changes: 1 addition & 1 deletion docs/modules/ROOT/examples/components/aws2-sns.yml
Original file line number Diff line number Diff line change
Expand Up @@ -9,5 +9,5 @@ cqJvmSince: 1.0.0
cqNativeSince: 1.0.0
cqCamelPartName: aws2-sns
cqCamelPartTitle: AWS Simple Notification System (SNS)
cqCamelPartDescription: Send messages to an AWS Simple Notification Topic using AWS SDK version 2.x.
cqCamelPartDescription: Send messages to AWS Simple Notification Topic.
cqExtensionPageTitle: AWS 2 Simple Notification System (SNS)
2 changes: 1 addition & 1 deletion docs/modules/ROOT/examples/components/aws2-sqs.yml
Original file line number Diff line number Diff line change
Expand Up @@ -9,5 +9,5 @@ cqJvmSince: 1.0.0
cqNativeSince: 1.0.0
cqCamelPartName: aws2-sqs
cqCamelPartTitle: AWS Simple Queue Service (SQS)
cqCamelPartDescription: Send and receive messages to/from AWS SQS service using AWS SDK version 2.x.
cqCamelPartDescription: Send and receive messages to/from AWS SQS.
cqExtensionPageTitle: AWS 2 Simple Queue Service (SQS)
2 changes: 1 addition & 1 deletion docs/modules/ROOT/examples/components/aws2-sts.yml
Original file line number Diff line number Diff line change
Expand Up @@ -9,5 +9,5 @@ cqJvmSince: 1.1.0
cqNativeSince: 1.1.0
cqCamelPartName: aws2-sts
cqCamelPartTitle: AWS Security Token Service (STS)
cqCamelPartDescription: Manage AWS STS cluster instances using AWS SDK version 2.x.
cqCamelPartDescription: Manage AWS STS cluster instances.
cqExtensionPageTitle: AWS 2 Security Token Service (STS)
4 changes: 2 additions & 2 deletions docs/modules/ROOT/pages/reference/extensions/aws2-cw.adoc
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
:cq-native-supported: true
:cq-status: Stable
:cq-status-deprecation: Stable
:cq-description: Sending metrics to AWS CloudWatch using AWS SDK version 2.x.
:cq-description: Sending metrics to AWS CloudWatch.
:cq-deprecated: false
:cq-jvm-since: 1.0.0
:cq-native-since: 1.0.0
Expand All @@ -18,7 +18,7 @@ ifeval::[{doc-show-badges} == true]
[.badge-key]##JVM since##[.badge-supported]##1.0.0## [.badge-key]##Native since##[.badge-supported]##1.0.0##
endif::[]

Sending metrics to AWS CloudWatch using AWS SDK version 2.x.
Sending metrics to AWS CloudWatch.

[id="extensions-aws2-cw-whats-inside"]
== What's inside
Expand Down
4 changes: 2 additions & 2 deletions docs/modules/ROOT/pages/reference/extensions/aws2-ec2.adoc
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
:cq-native-supported: true
:cq-status: Stable
:cq-status-deprecation: Stable
:cq-description: Manage AWS EC2 instances using AWS SDK version 2.x.
:cq-description: Manage AWS EC2 instances.
:cq-deprecated: false
:cq-jvm-since: 1.0.0
:cq-native-since: 1.0.0
Expand All @@ -18,7 +18,7 @@ ifeval::[{doc-show-badges} == true]
[.badge-key]##JVM since##[.badge-supported]##1.0.0## [.badge-key]##Native since##[.badge-supported]##1.0.0##
endif::[]

Manage AWS EC2 instances using AWS SDK version 2.x.
Manage AWS EC2 instances.

[id="extensions-aws2-ec2-whats-inside"]
== What's inside
Expand Down
4 changes: 2 additions & 2 deletions docs/modules/ROOT/pages/reference/extensions/aws2-ecs.adoc
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
:cq-native-supported: true
:cq-status: Stable
:cq-status-deprecation: Stable
:cq-description: Manage AWS ECS cluster instances using AWS SDK version 2.x.
:cq-description: Manage AWS ECS cluster instances.
:cq-deprecated: false
:cq-jvm-since: 1.0.0
:cq-native-since: 1.0.0
Expand All @@ -18,7 +18,7 @@ ifeval::[{doc-show-badges} == true]
[.badge-key]##JVM since##[.badge-supported]##1.0.0## [.badge-key]##Native since##[.badge-supported]##1.0.0##
endif::[]

Manage AWS ECS cluster instances using AWS SDK version 2.x.
Manage AWS ECS cluster instances.

[id="extensions-aws2-ecs-whats-inside"]
== What's inside
Expand Down
4 changes: 2 additions & 2 deletions docs/modules/ROOT/pages/reference/extensions/aws2-eks.adoc
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
:cq-native-supported: true
:cq-status: Stable
:cq-status-deprecation: Stable
:cq-description: Manage AWS EKS cluster instances using AWS SDK version 2.x.
:cq-description: Manage AWS EKS cluster instances.
:cq-deprecated: false
:cq-jvm-since: 1.0.0
:cq-native-since: 1.0.0
Expand All @@ -18,7 +18,7 @@ ifeval::[{doc-show-badges} == true]
[.badge-key]##JVM since##[.badge-supported]##1.0.0## [.badge-key]##Native since##[.badge-supported]##1.0.0##
endif::[]

Manage AWS EKS cluster instances using AWS SDK version 2.x.
Manage AWS EKS cluster instances.

[id="extensions-aws2-eks-whats-inside"]
== What's inside
Expand Down
4 changes: 2 additions & 2 deletions docs/modules/ROOT/pages/reference/extensions/aws2-iam.adoc
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
:cq-native-supported: true
:cq-status: Stable
:cq-status-deprecation: Stable
:cq-description: Manage AWS IAM instances using AWS SDK version 2.x.
:cq-description: Manage AWS IAM instances.
:cq-deprecated: false
:cq-jvm-since: 1.0.0
:cq-native-since: 1.0.0
Expand All @@ -18,7 +18,7 @@ ifeval::[{doc-show-badges} == true]
[.badge-key]##JVM since##[.badge-supported]##1.0.0## [.badge-key]##Native since##[.badge-supported]##1.0.0##
endif::[]

Manage AWS IAM instances using AWS SDK version 2.x.
Manage AWS IAM instances.

[id="extensions-aws2-iam-whats-inside"]
== What's inside
Expand Down
4 changes: 2 additions & 2 deletions docs/modules/ROOT/pages/reference/extensions/aws2-kms.adoc
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
:cq-native-supported: true
:cq-status: Stable
:cq-status-deprecation: Stable
:cq-description: Manage keys stored in AWS KMS instances using AWS SDK version 2.x.
:cq-description: Manage keys stored in AWS KMS instances.
:cq-deprecated: false
:cq-jvm-since: 1.0.0
:cq-native-since: 1.0.0
Expand All @@ -18,7 +18,7 @@ ifeval::[{doc-show-badges} == true]
[.badge-key]##JVM since##[.badge-supported]##1.0.0## [.badge-key]##Native since##[.badge-supported]##1.0.0##
endif::[]

Manage keys stored in AWS KMS instances using AWS SDK version 2.x.
Manage keys stored in AWS KMS instances.

[id="extensions-aws2-kms-whats-inside"]
== What's inside
Expand Down
4 changes: 2 additions & 2 deletions docs/modules/ROOT/pages/reference/extensions/aws2-mq.adoc
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
:cq-native-supported: true
:cq-status: Stable
:cq-status-deprecation: Stable
:cq-description: Manage AWS MQ instances using AWS SDK version 2.x.
:cq-description: Send messages to AWS MQ.
:cq-deprecated: false
:cq-jvm-since: 1.0.0
:cq-native-since: 1.0.0
Expand All @@ -18,7 +18,7 @@ ifeval::[{doc-show-badges} == true]
[.badge-key]##JVM since##[.badge-supported]##1.0.0## [.badge-key]##Native since##[.badge-supported]##1.0.0##
endif::[]

Manage AWS MQ instances using AWS SDK version 2.x.
Send messages to AWS MQ.

[id="extensions-aws2-mq-whats-inside"]
== What's inside
Expand Down
4 changes: 2 additions & 2 deletions docs/modules/ROOT/pages/reference/extensions/aws2-msk.adoc
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
:cq-native-supported: true
:cq-status: Stable
:cq-status-deprecation: Stable
:cq-description: Manage AWS MSK instances using AWS SDK version 2.x.
:cq-description: Manage AWS MSK instances.
:cq-deprecated: false
:cq-jvm-since: 1.0.0
:cq-native-since: 1.0.0
Expand All @@ -18,7 +18,7 @@ ifeval::[{doc-show-badges} == true]
[.badge-key]##JVM since##[.badge-supported]##1.0.0## [.badge-key]##Native since##[.badge-supported]##1.0.0##
endif::[]

Manage AWS MSK instances using AWS SDK version 2.x.
Manage AWS MSK instances.

[id="extensions-aws2-msk-whats-inside"]
== What's inside
Expand Down
4 changes: 2 additions & 2 deletions docs/modules/ROOT/pages/reference/extensions/aws2-s3.adoc
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
:cq-native-supported: true
:cq-status: Stable
:cq-status-deprecation: Stable
:cq-description: Store and retrieve objects from AWS S3 Storage Service using AWS SDK version 2.x.
:cq-description: Store and retrieve objects from AWS S3 Storage Service.
:cq-deprecated: false
:cq-jvm-since: 1.0.0
:cq-native-since: 1.0.0
Expand All @@ -18,7 +18,7 @@ ifeval::[{doc-show-badges} == true]
[.badge-key]##JVM since##[.badge-supported]##1.0.0## [.badge-key]##Native since##[.badge-supported]##1.0.0##
endif::[]

Store and retrieve objects from AWS S3 Storage Service using AWS SDK version 2.x.
Store and retrieve objects from AWS S3 Storage Service.

[id="extensions-aws2-s3-whats-inside"]
== What's inside
Expand Down
4 changes: 2 additions & 2 deletions docs/modules/ROOT/pages/reference/extensions/aws2-ses.adoc
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
:cq-native-supported: true
:cq-status: Stable
:cq-status-deprecation: Stable
:cq-description: Send e-mails through AWS SES service using AWS SDK version 2.x.
:cq-description: Send e-mails through AWS SES service.
:cq-deprecated: false
:cq-jvm-since: 1.0.0
:cq-native-since: 1.0.0
Expand All @@ -18,7 +18,7 @@ ifeval::[{doc-show-badges} == true]
[.badge-key]##JVM since##[.badge-supported]##1.0.0## [.badge-key]##Native since##[.badge-supported]##1.0.0##
endif::[]

Send e-mails through AWS SES service using AWS SDK version 2.x.
Send e-mails through AWS SES service.

[id="extensions-aws2-ses-whats-inside"]
== What's inside
Expand Down
4 changes: 2 additions & 2 deletions docs/modules/ROOT/pages/reference/extensions/aws2-sns.adoc
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
:cq-native-supported: true
:cq-status: Stable
:cq-status-deprecation: Stable
:cq-description: Send messages to an AWS Simple Notification Topic using AWS SDK version 2.x.
:cq-description: Send messages to AWS Simple Notification Topic.
:cq-deprecated: false
:cq-jvm-since: 1.0.0
:cq-native-since: 1.0.0
Expand All @@ -18,7 +18,7 @@ ifeval::[{doc-show-badges} == true]
[.badge-key]##JVM since##[.badge-supported]##1.0.0## [.badge-key]##Native since##[.badge-supported]##1.0.0##
endif::[]

Send messages to an AWS Simple Notification Topic using AWS SDK version 2.x.
Send messages to AWS Simple Notification Topic.

[id="extensions-aws2-sns-whats-inside"]
== What's inside
Expand Down
4 changes: 2 additions & 2 deletions docs/modules/ROOT/pages/reference/extensions/aws2-sqs.adoc
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
:cq-native-supported: true
:cq-status: Stable
:cq-status-deprecation: Stable
:cq-description: Send and receive messages to/from AWS SQS service using AWS SDK version 2.x.
:cq-description: Send and receive messages to/from AWS SQS.
:cq-deprecated: false
:cq-jvm-since: 1.0.0
:cq-native-since: 1.0.0
Expand All @@ -18,7 +18,7 @@ ifeval::[{doc-show-badges} == true]
[.badge-key]##JVM since##[.badge-supported]##1.0.0## [.badge-key]##Native since##[.badge-supported]##1.0.0##
endif::[]

Send and receive messages to/from AWS SQS service using AWS SDK version 2.x.
Send and receive messages to/from AWS SQS.

[id="extensions-aws2-sqs-whats-inside"]
== What's inside
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -88,11 +88,10 @@ public Response purgeQueue(@PathParam("queueName") String queueName) throws Exce
@Consumes(MediaType.TEXT_PLAIN)
@Produces(MediaType.TEXT_PLAIN)
public Response snsSend(String message,
@QueryParam("queueUrl") String queueUrl,
@DefaultValue("false") @QueryParam("fifo") boolean fifo) throws Exception {

String endpointUri = String.format(
"aws2-sns://%s?useDefaultCredentialsProvider=%s&subscribeSNStoSQS=true&queueUrl=RAW(%s)%s",
"aws2-sns://%s?useDefaultCredentialsProvider=%s&subscribeSNStoSQS=true&queueArn=RAW(%s)%s",
fifo ? fifoTopicName : topicName, isUseDefaultCredentials(),
fifo ? snsFifoReceiverQueueArn : snsReceiverQueueArn,
fifo ? "&messageGroupIdStrategy=useExchangeId" : "");
Expand Down
Loading

0 comments on commit 17290d0

Please sign in to comment.