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.

Reply via email to