This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch camel-3.14.x
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-3.14.x by this push:
new 152b53de0f6 CAMEL-18123 Aws2-sqs: Operations PurgeQueue and
DeleteQueue requires unnecessary header (#7635)
152b53de0f6 is described below
commit 152b53de0f61b8006d0e5abf36c4c67d8fc8e935
Author: JiriOndrusek <[email protected]>
AuthorDate: Thu May 19 06:30:20 2022 +0200
CAMEL-18123 Aws2-sqs: Operations PurgeQueue and DeleteQueue requires
unnecessary header (#7635)
---
.../apache/camel/component/aws2/sqs/Sqs2Producer.java | 8 ++------
.../camel/component/aws2/sqs/AmazonSQSClientMock.java | 19 +++++++++++++++++--
.../aws2/sqs/SqsProducerDeleteQueueTest.java | 5 ++---
.../component/aws2/sqs/SqsProducerPurgeTest.java | 2 +-
4 files changed, 22 insertions(+), 12 deletions(-)
diff --git
a/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Producer.java
b/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Producer.java
index b894703e2ed..f611b4775aa 100644
---
a/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Producer.java
+++
b/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Producer.java
@@ -181,9 +181,7 @@ public class Sqs2Producer extends DefaultProducer {
private void purgeQueue(SqsClient amazonSQS, Exchange exchange) {
PurgeQueueRequest.Builder request = PurgeQueueRequest.builder();
- if
(ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Sqs2Constants.SQS_QUEUE_PREFIX)))
{
- request.queueUrl(getQueueUrl());
- }
+ request.queueUrl(getQueueUrl());
PurgeQueueResponse result = amazonSQS.purgeQueue(request.build());
Message message = getMessageForResponse(exchange);
message.setBody(result);
@@ -191,9 +189,7 @@ public class Sqs2Producer extends DefaultProducer {
private void deleteQueue(SqsClient amazonSQS, Exchange exchange) {
DeleteQueueRequest.Builder request = DeleteQueueRequest.builder();
- if
(ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Sqs2Constants.SQS_QUEUE_PREFIX)))
{
- request.queueUrl(getQueueUrl());
- }
+ request.queueUrl(getQueueUrl());
DeleteQueueResponse result = amazonSQS.deleteQueue(request.build());
Message message = getMessageForResponse(exchange);
message.setBody(result);
diff --git
a/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/AmazonSQSClientMock.java
b/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/AmazonSQSClientMock.java
index ec48869d1f5..c50ea3b10a1 100644
---
a/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/AmazonSQSClientMock.java
+++
b/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/AmazonSQSClientMock.java
@@ -67,10 +67,15 @@ public class AmazonSQSClientMock implements SqsClient {
private Map<String, CreateQueueRequest> queues = new LinkedHashMap<>();
private Map<String, ScheduledFuture<?>> inFlight = new LinkedHashMap<>();
private ScheduledExecutorService scheduler;
+ private String queueName;
public AmazonSQSClientMock() {
}
+ public AmazonSQSClientMock(String queueName) {
+ this.queueName = queueName;
+ }
+
@Override
public ListQueuesResponse listQueues() {
return ListQueuesResponse.builder().build();
@@ -80,8 +85,12 @@ public class AmazonSQSClientMock implements SqsClient {
public ListQueuesResponse listQueues(ListQueuesRequest request) {
ListQueuesResponse.Builder result = ListQueuesResponse.builder();
List<String> queues = new ArrayList<>();
- queues.add("queue1");
- queues.add("queue2");
+ if (queueName != null) {
+ queues.add("/" + queueName);
+ } else {
+ queues.add("queue1");
+ queues.add("queue2");
+ }
result.queueUrls(queues);
return result.build();
}
@@ -187,12 +196,18 @@ public class AmazonSQSClientMock implements SqsClient {
@Override
public PurgeQueueResponse purgeQueue(PurgeQueueRequest purgeQueueRequest) {
+ if (purgeQueueRequest.queueUrl() == null) {
+ throw SqsException.builder().message("Queue name must be
specified.").build();
+ }
return PurgeQueueResponse.builder().build();
}
@Override
public DeleteQueueResponse deleteQueue(DeleteQueueRequest
deleteQueueRequest)
throws AwsServiceException, SdkClientException, SqsException {
+ if (deleteQueueRequest.queueUrl() == null) {
+ throw SqsException.builder().message("Queue name must be
specified.").build();
+ }
return DeleteQueueResponse.builder().build();
}
diff --git
a/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/SqsProducerDeleteQueueTest.java
b/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/SqsProducerDeleteQueueTest.java
index b9620910b56..6baf3a68b85 100644
---
a/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/SqsProducerDeleteQueueTest.java
+++
b/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/SqsProducerDeleteQueueTest.java
@@ -31,7 +31,7 @@ import static org.junit.jupiter.api.Assertions.assertNotNull;
public class SqsProducerDeleteQueueTest extends CamelTestSupport {
@BindToRegistry("client")
- AmazonSQSClientMock mock = new AmazonSQSClientMock();
+ AmazonSQSClientMock mock = new AmazonSQSClientMock("camel-1");
@EndpointInject("direct:start")
private ProducerTemplate template;
@@ -46,8 +46,7 @@ public class SqsProducerDeleteQueueTest extends
CamelTestSupport {
template.send("direct:start", new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
- exchange.getIn().setHeader(Sqs2Constants.SQS_QUEUE_PREFIX,
"camel-1");
+ public void process(Exchange exchange) {
}
});
assertMockEndpointsSatisfied();
diff --git
a/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/SqsProducerPurgeTest.java
b/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/SqsProducerPurgeTest.java
index 76043117562..c73e235cb9c 100644
---
a/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/SqsProducerPurgeTest.java
+++
b/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/SqsProducerPurgeTest.java
@@ -32,7 +32,7 @@ import static org.junit.jupiter.api.Assertions.assertNotNull;
public class SqsProducerPurgeTest extends CamelTestSupport {
@BindToRegistry("client")
- AmazonSQSClientMock mock = new AmazonSQSClientMock();
+ AmazonSQSClientMock mock = new AmazonSQSClientMock("camel-1");
@EndpointInject("direct:start")
private ProducerTemplate template;
