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 2020/07/30 09:32:20 UTC
[camel] 05/07: Camel-AWS2-SQS: Fixed CS
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 270ca12242c0c1a45153653f44423e00176f1431
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Jul 30 11:29:06 2020 +0200
Camel-AWS2-SQS: Fixed CS
---
.../java/org/apache/camel/component/aws2/sqs/Sqs2Producer.java | 2 +-
.../apache/camel/component/aws2/sqs/SqsProducerPurgeTest.java | 10 +++++-----
2 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/components/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Producer.java b/components/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Producer.java
index 2a4c4e1..5aa1950 100644
--- a/components/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Producer.java
+++ b/components/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Producer.java
@@ -83,7 +83,7 @@ public class Sqs2Producer extends DefaultProducer {
listQueues(getClient(), exchange);
break;
case purgeQueue:
- purgeQueue(getClient(), exchange);
+ purgeQueue(getClient(), exchange);
break;
default:
throw new IllegalArgumentException("Unsupported operation");
diff --git a/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/SqsProducerPurgeTest.java b/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/SqsProducerPurgeTest.java
index 22971f1..7604311 100644
--- a/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/SqsProducerPurgeTest.java
+++ b/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/SqsProducerPurgeTest.java
@@ -45,11 +45,11 @@ public class SqsProducerPurgeTest extends CamelTestSupport {
result.expectedMessageCount(1);
template.send("direct:start", new Processor() {
-
- @Override
- public void process(Exchange exchange) throws Exception {
- }
- });
+
+ @Override
+ public void process(Exchange exchange) throws Exception {
+ }
+ });
assertMockEndpointsSatisfied();
PurgeQueueResponse res = result.getExchanges().get(0).getIn().getBody(PurgeQueueResponse.class);
assertNotNull(res);