You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by gz...@apache.org on 2023/09/24 09:56:23 UTC
[camel] 01/04: Apply formatter on AWS components
This is an automated email from the ASF dual-hosted git repository.
gzurowski pushed a commit to branch release/3.21.1
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 93bce91523763ba154a486bea55c85d812d4ebdd
Author: Gregor Zurowski <gr...@zurowski.org>
AuthorDate: Sun Sep 24 11:54:30 2023 +0200
Apply formatter on AWS components
---
.../apache/camel/component/aws2/ddbstream/Ddb2StreamEndpoint.java | 2 --
.../main/java/org/apache/camel/component/aws2/sqs/Sqs2Consumer.java | 5 +++--
2 files changed, 3 insertions(+), 4 deletions(-)
diff --git a/components/camel-aws/camel-aws2-ddb/src/main/java/org/apache/camel/component/aws2/ddbstream/Ddb2StreamEndpoint.java b/components/camel-aws/camel-aws2-ddb/src/main/java/org/apache/camel/component/aws2/ddbstream/Ddb2StreamEndpoint.java
index 0c7ec0ec227..cde1e4b48e5 100644
--- a/components/camel-aws/camel-aws2-ddb/src/main/java/org/apache/camel/component/aws2/ddbstream/Ddb2StreamEndpoint.java
+++ b/components/camel-aws/camel-aws2-ddb/src/main/java/org/apache/camel/component/aws2/ddbstream/Ddb2StreamEndpoint.java
@@ -16,8 +16,6 @@
*/
package org.apache.camel.component.aws2.ddbstream;
-import java.net.URI;
-
import org.apache.camel.Category;
import org.apache.camel.Consumer;
import org.apache.camel.Processor;
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);