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:49 UTC
[camel] 02/02: AWS S3 Streaming Upload: Set a constant name for the executor related to timeout checker
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);