CAMEL-6967: Dont trunk file store if store not created yet.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/6f06403c Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/6f06403c Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/6f06403c Branch: refs/heads/camel-2.11.x Commit: 6f06403c223a776247c00a0e0bedb699b46bfd78 Parents: fef28ef Author: Claus Ibsen <davscl...@apache.org> Authored: Mon Nov 18 11:50:00 2013 +0100 Committer: Claus Ibsen <davscl...@apache.org> Committed: Mon Nov 18 11:50:31 2013 +0100 ---------------------------------------------------------------------- .../processor/idempotent/FileIdempotentRepository.java | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/6f06403c/camel-core/src/main/java/org/apache/camel/processor/idempotent/FileIdempotentRepository.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/processor/idempotent/FileIdempotentRepository.java b/camel-core/src/main/java/org/apache/camel/processor/idempotent/FileIdempotentRepository.java index f6cab47..f2452ee 100644 --- a/camel-core/src/main/java/org/apache/camel/processor/idempotent/FileIdempotentRepository.java +++ b/camel-core/src/main/java/org/apache/camel/processor/idempotent/FileIdempotentRepository.java @@ -250,6 +250,10 @@ public class FileIdempotentRepository extends ServiceSupport implements Idempote * to the file store. */ protected void trunkStore() { + if (fileStore == null || !fileStore.exists()) { + return; + } + LOG.info("Trunking idempotent filestore: {}", fileStore); FileOutputStream fos = null; try { @@ -269,12 +273,12 @@ public class FileIdempotentRepository extends ServiceSupport implements Idempote * Loads the given file store into the 1st level cache */ protected void loadStore() { - LOG.trace("Loading to 1st level cache from idempotent filestore: {}", fileStore); - - if (!fileStore.exists()) { + if (fileStore == null || !fileStore.exists()) { return; } + LOG.trace("Loading to 1st level cache from idempotent filestore: {}", fileStore); + cache.clear(); Scanner scanner = null; try {
