This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch camel-3.x
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-3.x by this push:
new 5b314ff577e Regen for commit c6d4331317c6c541f2284e776fe41f89315f626f
(#10833)
5b314ff577e is described below
commit 5b314ff577e0d7c21713a0c39384606f45a86224
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed Jul 26 13:46:44 2023 +0200
Regen for commit c6d4331317c6c541f2284e776fe41f89315f626f (#10833)
Signed-off-by: GitHub <[email protected]>
Co-authored-by: davsclaus <[email protected]>
---
.../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 a1688a5ebc0..2c86d8722a1 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
@@ -207,7 +207,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());
}
}
});
@@ -420,7 +421,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);