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

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


The following commit(s) were added to refs/heads/camel-3.18.x by this push:
     new 98c46d8061c CAMEL-18371: do load the cache when resuming with the file 
component
98c46d8061c is described below

commit 98c46d8061c015a8784a44001f4180ec6e2aed33
Author: Otavio Rodolfo Piske <[email protected]>
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 f666cb1cff0..f7998eec7fa 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
@@ -29,6 +29,8 @@ import org.apache.camel.resume.Deserializable;
 import org.apache.camel.resume.Offset;
 import org.apache.camel.resume.OffsetKey;
 import org.apache.camel.resume.cache.ResumeCache;
+import org.apache.camel.support.resume.OffsetKeys;
+import org.apache.camel.support.resume.Offsets;
 
 public class FileResumeAdapterDelegate
         implements FileResumeAdapter, Cacheable, Deserializable, 
FileOffsetResumeAdapter, DirectoryEntriesResumeAdapter {
@@ -81,7 +83,7 @@ public class FileResumeAdapterDelegate
             fileOffsetResumeAdapter.deserializeFileOffset((File) keyObj, 
(Long) valueObj);
         }
 
-        return true;
+        return add(OffsetKeys.of(keyObj), Offsets.of(valueObj));
     }
 
     @Override

Reply via email to