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