You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2022/08/10 15:01:17 UTC

[camel] 01/02: CAMEL-18371: do load the cache when resuming with the file component

This is an automated email from the ASF dual-hosted git repository.

orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 7a50e23dde3f986a1d55560047d7ee432369314f
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Aug 9 16:54:18 2022 +0200

    CAMEL-18371: do load the cache when resuming with the file component
---
 .../component/file/consumer/adapters/FileResumeAdapterDelegate.java   | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/components/camel-file/src/main/java/org/apache/camel/component/file/consumer/adapters/FileResumeAdapterDelegate.java b/components/camel-file/src/main/java/org/apache/camel/component/file/consumer/adapters/FileResumeAdapterDelegate.java
index f00229329f6..c5f0ffaa2c9 100644
--- a/components/camel-file/src/main/java/org/apache/camel/component/file/consumer/adapters/FileResumeAdapterDelegate.java
+++ b/components/camel-file/src/main/java/org/apache/camel/component/file/consumer/adapters/FileResumeAdapterDelegate.java
@@ -30,6 +30,8 @@ import org.apache.camel.resume.Offset;
 import org.apache.camel.resume.OffsetKey;
 import org.apache.camel.resume.cache.ResumeCache;
 import org.apache.camel.spi.annotations.JdkService;
+import org.apache.camel.support.resume.OffsetKeys;
+import org.apache.camel.support.resume.Offsets;
 
 @JdkService("file-adapter-factory")
 public class FileResumeAdapterDelegate
@@ -83,7 +85,7 @@ public class FileResumeAdapterDelegate
             fileOffsetResumeAdapter.deserializeFileOffset((File) keyObj, (Long) valueObj);
         }
 
-        return true;
+        return add(OffsetKeys.of(keyObj), Offsets.of(valueObj));
     }
 
     @Override