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);