You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2023/09/01 04:42:36 UTC
[camel] 02/02: Regen
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch aws-sdk-2.20.138
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 1d1a6ffa67c00a8461389bd180ac858b39f58d24
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Sep 1 06:42:02 2023 +0200
Regen
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../camel/component/aws2/s3/stream/AWS2S3StreamUploadProducer.java | 2 +-
.../java/org/apache/camel/component/aws2/s3/utils/AWS2S3Utils.java | 1 -
.../camel/component/aws2/s3/integration/S3StreamUploadTimeoutIT.java | 4 ++--
.../java/org/apache/camel/component/mllp/MllpTcpClientProducer.java | 1 -
.../src/main/java/org/apache/camel/component/seda/SedaEndpoint.java | 3 ---
5 files changed, 3 insertions(+), 8 deletions(-)
diff --git a/components/camel-aws/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/stream/AWS2S3StreamUploadProducer.java b/components/camel-aws/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/stream/AWS2S3StreamUploadProducer.java
index e0a9e69beb2..138995c6e59 100644
--- a/components/camel-aws/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/stream/AWS2S3StreamUploadProducer.java
+++ b/components/camel-aws/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/stream/AWS2S3StreamUploadProducer.java
@@ -213,7 +213,7 @@ public class AWS2S3StreamUploadProducer extends DefaultProducer {
}
state = null;
}
-
+
} catch (Exception e) {
getEndpoint().getS3Client()
.abortMultipartUpload(AbortMultipartUploadRequest.builder().bucket(getConfiguration().getBucketName())
diff --git a/components/camel-aws/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/utils/AWS2S3Utils.java b/components/camel-aws/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/utils/AWS2S3Utils.java
index d99e4405afa..fa166fdcdb8 100644
--- a/components/camel-aws/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/utils/AWS2S3Utils.java
+++ b/components/camel-aws/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/utils/AWS2S3Utils.java
@@ -26,7 +26,6 @@ import org.apache.camel.StreamCache;
import org.apache.camel.component.aws2.s3.AWS2S3Configuration;
import org.apache.camel.component.aws2.s3.AWS2S3Constants;
import org.apache.camel.util.ObjectHelper;
-import org.apache.camel.util.StringHelper;
import software.amazon.awssdk.services.s3.model.CreateMultipartUploadRequest;
import software.amazon.awssdk.services.s3.model.ServerSideEncryption;
diff --git a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3StreamUploadTimeoutIT.java b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3StreamUploadTimeoutIT.java
index f1eef645c19..d8d52d687ec 100644
--- a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3StreamUploadTimeoutIT.java
+++ b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3StreamUploadTimeoutIT.java
@@ -43,9 +43,9 @@ public class S3StreamUploadTimeoutIT extends Aws2S3Base {
@Test
public void sendIn() throws Exception {
- for(int i = 1; i <= 2; i++) {
+ for (int i = 1; i <= 2; i++) {
int count = i * 23;
-
+
result.expectedMessageCount(count);
for (int j = 0; j < 23; j++) {
diff --git a/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/MllpTcpClientProducer.java b/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/MllpTcpClientProducer.java
index 19796a11e4b..802d7b8914b 100644
--- a/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/MllpTcpClientProducer.java
+++ b/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/MllpTcpClientProducer.java
@@ -112,7 +112,6 @@ public class MllpTcpClientProducer extends DefaultProducer implements Runnable {
String fullEndpointKey = getEndpoint().getEndpointKey();
String endpointKey = StringHelper.before(fullEndpointKey, "?", fullEndpointKey);
-
idleTimeoutExecutor = Executors.newSingleThreadScheduledExecutor(new IdleTimeoutThreadFactory(endpointKey));
}
diff --git a/components/camel-seda/src/main/java/org/apache/camel/component/seda/SedaEndpoint.java b/components/camel-seda/src/main/java/org/apache/camel/component/seda/SedaEndpoint.java
index e59dc325e1e..7f9f58d0398 100644
--- a/components/camel-seda/src/main/java/org/apache/camel/component/seda/SedaEndpoint.java
+++ b/components/camel-seda/src/main/java/org/apache/camel/component/seda/SedaEndpoint.java
@@ -221,7 +221,6 @@ public class SedaEndpoint extends DefaultEndpoint implements AsyncEndpoint, Brow
}
}
-
protected synchronized AsyncProcessor getConsumerMulticastProcessor() {
if (!multicastStarted && consumerMulticastProcessor != null) {
// only start it on-demand to avoid starting it during stopping
@@ -589,6 +588,4 @@ public class SedaEndpoint extends DefaultEndpoint implements AsyncEndpoint, Brow
queue = null;
}
-
-
}