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