This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
commit 6f4ba3f9d2761f8ee271f2e9a61abae7fd2e7bef Author: Claus Ibsen <claus.ib...@gmail.com> AuthorDate: Thu Mar 29 13:36:47 2018 +0200 CAMEL-12382: FileConsumer - Allow to delay readLock release tasks on idempotent read-lock --- .../file/strategy/FileIdempotentChangedRepositoryReadLockStrategy.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/camel-core/src/main/java/org/apache/camel/component/file/strategy/FileIdempotentChangedRepositoryReadLockStrategy.java b/camel-core/src/main/java/org/apache/camel/component/file/strategy/FileIdempotentChangedRepositoryReadLockStrategy.java index 0f12f00..7ae8ba2 100644 --- a/camel-core/src/main/java/org/apache/camel/component/file/strategy/FileIdempotentChangedRepositoryReadLockStrategy.java +++ b/camel-core/src/main/java/org/apache/camel/component/file/strategy/FileIdempotentChangedRepositoryReadLockStrategy.java @@ -307,7 +307,8 @@ public class FileIdempotentChangedRepositoryReadLockStrategy extends ServiceSupp ObjectHelper.notNull(idempotentRepository, "idempotentRepository", this); if (readLockIdempotentReleaseAsync && readLockIdempotentReleaseExecutorService == null) { - readLockIdempotentReleaseExecutorService = camelContext.getExecutorServiceManager().newScheduledThreadPool(this, "ReadLockChangedIdempotentReleaseTask", readLockIdempotentReleaseAsyncPoolSize); + readLockIdempotentReleaseExecutorService = camelContext.getExecutorServiceManager().newScheduledThreadPool( + this, "ReadLockChangedIdempotentReleaseTask", readLockIdempotentReleaseAsyncPoolSize); shutdownExecutorService = true; } } -- To stop receiving notification emails like this one, please contact davscl...@apache.org.