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 <[email protected]> AuthorDate: Fri Sep 1 06:42:02 2023 +0200 Regen Signed-off-by: Andrea Cosentino <[email protected]> --- .../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; } - - }
