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 7a33814cb74844f6ed02e02e71c5143cd2d92db7 Author: Otavio Rodolfo Piske <orpi...@users.noreply.github.com> AuthorDate: Thu May 12 06:31:09 2022 +0200 (chores) Minor cosmetic change on camel-base-engine to make checkstyle happy (#7599) --- .../org/apache/camel/impl/engine/DefaultStreamCachingStrategy.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultStreamCachingStrategy.java b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultStreamCachingStrategy.java index 88eb40a706d..0e418fe9808 100644 --- a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultStreamCachingStrategy.java +++ b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultStreamCachingStrategy.java @@ -347,7 +347,7 @@ public class DefaultStreamCachingStrategy extends ServiceSupport implements Came @Override protected void doStop() throws Exception { - if (spoolEnabled && (spoolThreshold > 0 & spoolDirectory != null && isRemoveSpoolDirectoryWhenStopping())) { + if (spoolEnabled && isSpoolRemovable()) { LOG.debug("Removing spool directory: {}", spoolDirectory); FileUtil.removeDir(spoolDirectory); } @@ -359,6 +359,10 @@ public class DefaultStreamCachingStrategy extends ServiceSupport implements Came statistics.reset(); } + private boolean isSpoolRemovable() { + return spoolThreshold > 0 & spoolDirectory != null && isRemoveSpoolDirectoryWhenStopping(); + } + @Override public String toString() { return "DefaultStreamCachingStrategy["