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

クラス ListenerContainerPauseService

java.lang.ObjectSE
org.springframework.kafka.listener.ListenerContainerPauseService
public class ListenerContainerPauseService extends ObjectSE
MessageListenerContainer の一時停止と再開のためのサービス。
導入:
2.9
作成者:
Jan Marincek, Gary Russell

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

    • ListenerContainerPauseService

      public ListenerContainerPauseService(@Nullable ListenerContainerRegistry registry, TaskScheduler scheduler)
      提供されたレジストリとスケジューラを使用してインスタンスを作成します。
      パラメーター:
      registry - レジストリまたは null。
      scheduler - スケジューラー。

  • メソッドの詳細

    • pause

      public void pause(StringSE listenerId, DurationSE pauseDuration)
      指定された ID でリスナーを一時停止します。リスナーがすでに一時停止をリクエストされているかどうかを確認します。pauseDuration の後に同じリスナーを再開するためのエグゼキュータスケジュールを設定します。
      パラメーター:
      listenerId - リスナーの ID
      pauseDuration - pause() アクションと resume() アクション間の期間

    • pause

      public void pause(MessageListenerContainer messageListenerContainer, DurationSE pauseDuration)
      指定されたコンテナーインスタンスによってリスナーを一時停止します。リスナーがすでに一時停止をリクエストされているかどうかを確認します。pauseDuration の後に同じリスナーを再開するためのエグゼキュータスケジュールを設定します。
      パラメーター:
      messageListenerContainer - リスナーコンテナー
      pauseDuration - pause() アクションと resume() アクション間の期間

    • pausePartition

      public void pausePartition(MessageListenerContainer messageListenerContainer, org.apache.kafka.common.TopicPartition partition, DurationSE pauseDuration)
      期間中、特定のパーティションからの消費を一時停止します。
      パラメーター:
      messageListenerContainer - コンテナー。
      partition - パーティション。
      pauseDuration - デュレーション。

    • resume

      public void resume(StringSE listenerId)
      指定された ID でリスナーコンテナーを再開します。
      パラメーター:
      listenerId - リスナーの ID

    • resume

      public void resume(MessageListenerContainer messageListenerContainer)
      リスナーコンテナーを再開します。
      パラメーター:
      messageListenerContainer - リスナーコンテナー