This is an automated email from the ASF dual-hosted git repository.

gzurowski pushed a commit to branch camel-3.20.x
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 79123c58a4efe65be251facb932bf997bcbd7bc3
Author: Gregor Zurowski <gre...@zurowski.org>
AuthorDate: Tue Sep 26 10:57:13 2023 +0200

    Apply formatter on aws2-sqs component
---
 .../main/java/org/apache/camel/component/aws2/sqs/Sqs2Consumer.java  | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Consumer.java
 
b/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Consumer.java
index c9f27c93d1d..2c430257a3a 100644
--- 
a/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Consumer.java
+++ 
b/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Consumer.java
@@ -203,7 +203,8 @@ public class Sqs2Consumer extends 
ScheduledBatchPollingConsumer {
                         extender.cancel();
                         boolean cancelled = scheduledFuture.cancel(true);
                         if (!cancelled) {
-                            LOG.warn("TimeoutExtender task for exchangeId: {} 
could not be cancelled", exchange.getExchangeId());
+                            LOG.warn("TimeoutExtender task for exchangeId: {} 
could not be cancelled",
+                                    exchange.getExchangeId());
                         }
                     }
                 });
@@ -406,7 +407,7 @@ public class Sqs2Consumer extends 
ScheduledBatchPollingConsumer {
             if (run.get()) {
                 ChangeMessageVisibilityRequest.Builder request
                         = 
ChangeMessageVisibilityRequest.builder().queueUrl(getQueueUrl()).visibilityTimeout(repeatSeconds)
-                        
.receiptHandle(exchange.getIn().getHeader(Sqs2Constants.RECEIPT_HANDLE, 
String.class));
+                                
.receiptHandle(exchange.getIn().getHeader(Sqs2Constants.RECEIPT_HANDLE, 
String.class));
 
                 try {
                     LOG.trace("Extending visibility window by {} seconds for 
exchange {}", this.repeatSeconds, this.exchange);

Reply via email to