@FunctionalInterfaceSE public interface MessageBatchRecoverer extends MessageRecoverer
| 修飾子と型 | メソッドと説明 |
|---|---|
void | recover(ListSE<Message> messages, ThrowableSE cause) 消費されましたがすべての再試行に失敗したメッセージバッチのコールバック。 |
default void | recover(Message message, ThrowableSE cause) 消費されましたがすべての再試行に失敗したメッセージのコールバック。 |
default void recover(Message message, ThrowableSE cause)
MessageRecovererMessageRecoverer 内の recover message - 回復へのメッセージ cause - エラーの原因 void recover(ListSE<Message> messages, ThrowableSE cause)
messages - 回復するメッセージ cause - エラーの原因