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 <[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 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
