This is an automated email from the ASF dual-hosted git repository.
jiriondrusek pushed a commit to branch camel-main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
The following commit(s) were added to refs/heads/camel-main by this push:
new f3ec265db9 Fixed aws2 because of CAMEL-19737
f3ec265db9 is described below
commit f3ec265db9e63b0611f9535b6e30294b8d248517
Author: JiriOndrusek <[email protected]>
AuthorDate: Wed Aug 30 15:22:31 2023 +0200
Fixed aws2 because of CAMEL-19737
---
.../apache/camel/quarkus/component/aws2/sns/it/Aws2SqsSnsResource.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git
a/integration-test-groups/aws2/aws2-sqs-sns/src/main/java/org/apache/camel/quarkus/component/aws2/sns/it/Aws2SqsSnsResource.java
b/integration-test-groups/aws2/aws2-sqs-sns/src/main/java/org/apache/camel/quarkus/component/aws2/sns/it/Aws2SqsSnsResource.java
index 6708491498..8ef9997175 100644
---
a/integration-test-groups/aws2/aws2-sqs-sns/src/main/java/org/apache/camel/quarkus/component/aws2/sns/it/Aws2SqsSnsResource.java
+++
b/integration-test-groups/aws2/aws2-sqs-sns/src/main/java/org/apache/camel/quarkus/component/aws2/sns/it/Aws2SqsSnsResource.java
@@ -88,11 +88,10 @@ public class Aws2SqsSnsResource extends BaseAws2Resource {
@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" : "");