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 <anco...@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);

Reply via email to