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 2022/04/20 11:39:47 UTC
[camel] branch main updated (c61a7ef9183 -> 06f33c14379)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
from c61a7ef9183 CAMEL-17894: fix a few string concatenations in the SpiGenerator
new 06676866ff6 AWS S3 Streaming Upload: Set a constant name for the executor related to timeout checker
new 06f33c14379 AWS S3 Streaming Upload: Set a constant name for the executor related to timeout checker
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../camel/component/aws2/s3/stream/AWS2S3StreamUploadProducer.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
[camel] 02/02: AWS S3 Streaming Upload: Set a constant name for the executor related to timeout checker
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 06f33c14379b13576d16ebfacb2401e884bea75b
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Apr 20 13:35:53 2022 +0200
AWS S3 Streaming Upload: Set a constant name for the executor related to timeout checker
---
.../camel/component/aws2/s3/stream/AWS2S3StreamUploadProducer.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 03d990e0ce4..c3e03ff086c 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
@@ -84,7 +84,7 @@ public class AWS2S3StreamUploadProducer extends DefaultProducer {
if (getConfiguration().getStreamingUploadTimeout() > 0) {
timeoutCheckerExecutorService
= getEndpoint().getCamelContext().getExecutorServiceManager().newSingleThreadScheduledExecutor(this,
- TIMEOUT_CHECKER_EXECUTOR_NAME);
+ TIMEOUT_CHECKER_EXECUTOR_NAME);
timeoutCheckerExecutorService.scheduleAtFixedRate(new StreamingUploadTimeoutTask(),
getConfiguration().getStreamingUploadTimeout(), getConfiguration().getStreamingUploadTimeout(),
TimeUnit.MILLISECONDS);
[camel] 01/02: AWS S3 Streaming Upload: Set a constant name for the executor related to timeout checker
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 06676866ff632d049e6d5afeeb1b26e7682b3986
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Apr 20 13:27:47 2022 +0200
AWS S3 Streaming Upload: Set a constant name for the executor related to timeout checker
---
.../camel/component/aws2/s3/stream/AWS2S3StreamUploadProducer.java | 4 ++--
1 file changed, 2 insertions(+), 2 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 77591e3193c..03d990e0ce4 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
@@ -62,7 +62,7 @@ import software.amazon.awssdk.utils.IoUtils;
public class AWS2S3StreamUploadProducer extends DefaultProducer {
private static final Logger LOG = LoggerFactory.getLogger(AWS2S3StreamUploadProducer.class);
-
+ private static final String TIMEOUT_CHECKER_EXECUTOR_NAME = "S3_Streaming_Upload_Timeout_Checker";
ByteArrayOutputStream buffer = new ByteArrayOutputStream();
CreateMultipartUploadResponse initResponse;
AtomicInteger index = new AtomicInteger(1);
@@ -84,7 +84,7 @@ public class AWS2S3StreamUploadProducer extends DefaultProducer {
if (getConfiguration().getStreamingUploadTimeout() > 0) {
timeoutCheckerExecutorService
= getEndpoint().getCamelContext().getExecutorServiceManager().newSingleThreadScheduledExecutor(this,
- "timeout_checker");
+ TIMEOUT_CHECKER_EXECUTOR_NAME);
timeoutCheckerExecutorService.scheduleAtFixedRate(new StreamingUploadTimeoutTask(),
getConfiguration().getStreamingUploadTimeout(), getConfiguration().getStreamingUploadTimeout(),
TimeUnit.MILLISECONDS);