This is an automated email from the ASF dual-hosted git repository. github-bot pushed a commit to branch camel-main in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit db1dbb4dd534915a3cb0bc80e8b5be3842095dc3 Author: JiriOndrusek <ondrusek.j...@gmail.com> 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" : "");