You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2023/07/26 11:46:50 UTC
[camel] branch camel-3.x updated: Regen for commit c6d4331317c6c541f2284e776fe41f89315f626f (#10833)
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] <41...@users.noreply.github.com>
AuthorDate: Wed Jul 26 13:46:44 2023 +0200
Regen for commit c6d4331317c6c541f2284e776fe41f89315f626f (#10833)
Signed-off-by: GitHub <no...@github.com>
Co-authored-by: davsclaus <da...@users.noreply.github.com>
---
.../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);