You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2022/10/13 10:25:50 UTC
[camel] branch main updated: Regen for commit 2d17d59d20f905b511a8eeb0aae933b56bd0feb0
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 5c19cd71de8 Regen for commit 2d17d59d20f905b511a8eeb0aae933b56bd0feb0
5c19cd71de8 is described below
commit 5c19cd71de808b24cf42039e751d5b8d7e6d1418
Author: oscerd <os...@users.noreply.github.com>
AuthorDate: Thu Oct 13 10:23:41 2022 +0000
Regen for commit 2d17d59d20f905b511a8eeb0aae933b56bd0feb0
Signed-off-by: GitHub <no...@github.com>
---
.../org/apache/camel/resume/ResumeStrategy.java | 22 +++++++++++-----------
1 file changed, 11 insertions(+), 11 deletions(-)
diff --git a/core/camel-api/src/main/java/org/apache/camel/resume/ResumeStrategy.java b/core/camel-api/src/main/java/org/apache/camel/resume/ResumeStrategy.java
index f565961f028..10aed024a65 100644
--- a/core/camel-api/src/main/java/org/apache/camel/resume/ResumeStrategy.java
+++ b/core/camel-api/src/main/java/org/apache/camel/resume/ResumeStrategy.java
@@ -31,6 +31,7 @@ public interface ResumeStrategy extends Service {
interface UpdateCallBack {
/**
* The method to execute after the last offset is updated
+ *
* @param throwable an instance of a Throwable if an exception was thrown during the update process
*/
void onUpdate(Throwable throwable);
@@ -78,32 +79,31 @@ public interface ResumeStrategy extends Service {
*/
<T extends Resumable> void updateLastOffset(T offset) throws Exception;
-
/**
* Updates the last processed offset
*
- * @param offset the offset to update
- * @param updateCallBack a callback to be executed after the updated has occurred (null if not available)
- * @throws Exception if unable to update the offset
+ * @param offset the offset to update
+ * @param updateCallBack a callback to be executed after the updated has occurred (null if not available)
+ * @throws Exception if unable to update the offset
*/
<T extends Resumable> void updateLastOffset(T offset, UpdateCallBack updateCallBack) throws Exception;
/**
* Updates the last processed offset
*
- * @param offsetKey the offset key to update
- * @param offsetValue the offset value to update
- * @throws Exception if unable to update the offset
+ * @param offsetKey the offset key to update
+ * @param offsetValue the offset value to update
+ * @throws Exception if unable to update the offset
*/
void updateLastOffset(OffsetKey<?> offsetKey, Offset<?> offsetValue) throws Exception;
/**
* Updates the last processed offset
*
- * @param offsetKey the offset key to update
- * @param offset the offset value to update
- * @param updateCallBack a callback to be executed after the updated has occurred (null if not available)
- * @throws Exception if unable to update the offset
+ * @param offsetKey the offset key to update
+ * @param offset the offset value to update
+ * @param updateCallBack a callback to be executed after the updated has occurred (null if not available)
+ * @throws Exception if unable to update the offset
*/
void updateLastOffset(OffsetKey<?> offsetKey, Offset<?> offset, UpdateCallBack updateCallBack) throws Exception;
}