パッケージ org.springframework.kafka.listener.adapter

クラス AbstractRetryingMessageListenerAdapter<K,V,T>

java.lang.ObjectSE
org.springframework.kafka.listener.adapter.AbstractDelegatingMessageListenerAdapter<T>
org.springframework.kafka.listener.adapter.AbstractRetryingMessageListenerAdapter<K,V,T>
型パラメーター:
K - 鍵の型。
V - 値の型。
T - デリゲート型。
実装されたすべてのインターフェース:
ConsumerSeekAware, DelegatingMessageListener<T>
public abstract class AbstractRetryingMessageListenerAdapter<K,V,T> extends AbstractDelegatingMessageListenerAdapter<T>
メッセージリスナーアダプターを再試行するための基本クラス。
作成者:
Gary Russell

  • コンストラクターの詳細

    • AbstractRetryingMessageListenerAdapter

      public AbstractRetryingMessageListenerAdapter(T delegate, org.springframework.retry.support.RetryTemplate retryTemplate)
      提供された再試行テンプレートを使用してインスタンスを構築します。再試行が終了すると、例外がコンテナーにスローされます。
      パラメーター:
      delegate - デリゲートリスナー。
      retryTemplate - テンプレート。

    • AbstractRetryingMessageListenerAdapter

      public AbstractRetryingMessageListenerAdapter(T delegate, org.springframework.retry.support.RetryTemplate retryTemplate, @Nullable org.springframework.retry.RecoveryCallback<? extends ObjectSE> recoveryCallback)
      提供されたテンプレートとコールバックを使用してインスタンスを構築します。
      パラメーター:
      delegate - デリゲートリスナー。
      retryTemplate - テンプレート。
      recoveryCallback - リカバリコールバック。null の場合、再試行が終了した後、例外がコンテナーにスローされます。

  • メソッドの詳細

    • getRetryTemplate

      public org.springframework.retry.support.RetryTemplate getRetryTemplate()

    • getRecoveryCallback

      public org.springframework.retry.RecoveryCallback<? extends ObjectSE> getRecoveryCallback()