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

クラス AbstractDelegatingMessageListenerAdapter<T>

java.lang.ObjectSE
org.springframework.kafka.listener.adapter.AbstractDelegatingMessageListenerAdapter<T>
型パラメーター:
T - デリゲート型。
実装されたすべてのインターフェース:
ConsumerSeekAware, DelegatingMessageListener<T>
既知の直属サブクラス
AbstractFilteringMessageListener、AbstractRetryingMessageListenerAdapter、KafkaBackoffAwareMessageListenerAdapter
public abstract class AbstractDelegatingMessageListenerAdapter<T> extends ObjectSE implements ConsumerSeekAware, DelegatingMessageListener<T>
すべてのリスナーアダプターの最上位クラス。
導入:
1.1
作成者:
Gary Russell

  • フィールドの詳細

    • logger

      protected final LogAccessor logger

    • delegate

      protected final T delegate

    • delegateType

      protected final ListenerType delegateType

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

    • AbstractDelegatingMessageListenerAdapter

      public AbstractDelegatingMessageListenerAdapter(T delegate)

  • メソッドの詳細

    • getDelegate

      public T getDelegate()
      インターフェースからコピーされた説明: DelegatingMessageListener
      代理人を返します。
      次で指定:
      インターフェース DelegatingMessageListener<T> の getDelegate 
      戻り値:
      代表者。

    • registerSeekCallback

      public void registerSeekCallback(ConsumerSeekAware.ConsumerSeekCallback callback)
      インターフェースからコピーされた説明: ConsumerSeekAware
      任意のタイミングでシークする際に使用するコールバックを登録します。ConcurrentMessageListenerContainer または複数のコンテナー内の同じリスナーインスタンスで使用する場合、リスナーはコールバックを ThreadLocal またはスレッドによってキー設定されたマップに保存する必要があります。
      次で指定:
      インターフェース ConsumerSeekAware の registerSeekCallback 
      パラメーター:
      callback - コールバック。

    • onPartitionsAssigned

      public void onPartitionsAssigned(MapSE<org.apache.kafka.common.TopicPartition,LongSE> assignments, ConsumerSeekAware.ConsumerSeekCallback callback)
      インターフェースからコピーされた説明: ConsumerSeekAware
      グループ管理を使用する場合。パーティションの割り当てが変更されたときに呼び出されます。
      次で指定:
      インターフェース ConsumerSeekAware の onPartitionsAssigned 
      パラメーター:
      assignments - 新しい割り当てとその現在のオフセット。
      callback - 割り当て後に最初のシークを実行するためのコールバック。

    • onPartitionsRevoked

      public void onPartitionsRevoked(CollectionSE<org.apache.kafka.common.TopicPartition> partitions)
      インターフェースからコピーされた説明: ConsumerSeekAware
      グループ管理を使用する場合。パーティションの割り当てが取り消されたときに呼び出されます。リスナーは、このスレッドで ConsumerSeekAware.registerSeekCallback(ConsumerSeekCallback) から保存されたコールバックを破棄する必要があります。
      次で指定:
      インターフェース ConsumerSeekAware の onPartitionsRevoked 
      パラメーター:
      partitions - 取り消されたパーティション。

    • onIdleContainer

      public void onIdleContainer(MapSE<org.apache.kafka.common.TopicPartition,LongSE> assignments, ConsumerSeekAware.ConsumerSeekCallback callback)
      インターフェースからコピーされた説明: ConsumerSeekAware
      コンテナーがアイドルコンテナーイベントを発行するように構成されている場合、このメソッドはコンテナーアイドルイベントが発行されたときに呼び出され、シーク操作を許可します。
      次で指定:
      インターフェース ConsumerSeekAware の onIdleContainer 
      パラメーター:
      assignments - 新しい割り当てとその現在のオフセット。
      callback - シークを実行するためのコールバック。