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

クラス ContainerGroup

java.lang.ObjectSE
org.springframework.kafka.listener.ContainerGroup
実装されたすべてのインターフェース:
Lifecycle
public class ContainerGroup extends ObjectSE implements Lifecycle
リスナーコンテナーのグループ。
導入:
2.7.3
作成者:
Gary Russell

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

    • ContainerGroup

      public ContainerGroup(StringSE name)
      指定された名前でインスタンスを作成します。
      パラメーター:
      name - グループ名。

    • ContainerGroup

      public ContainerGroup(StringSE name, ListSE<MessageListenerContainer> containers)
      指定された名前とコンテナーを使用してインスタンスを作成します。
      パラメーター:
      name - グループ名。
      containers - コンテナー。

    • ContainerGroup

      public ContainerGroup(StringSE name, MessageListenerContainer... containers)
      指定された名前とコンテナーを使用してインスタンスを作成します。
      パラメーター:
      name - グループ名。
      containers - コンテナー。

  • メソッドの詳細

    • getName

      public StringSE getName()
      グループ名を返します。
      戻り値:
      名前。

    • getListenerIds

      public CollectionSE<StringSE> getListenerIds()
      このグループのコンテナーのリスナー ID を返します。
      戻り値:
      リスナー ID。

    • contains

      public boolean contains(MessageListenerContainer container)
      指定されたコンテナーがこのグループにある場合は true を返します。
      パラメーター:
      container - コンテナー。
      戻り値:
      このグループに含まれている場合は true。

    • allStopped

      public boolean allStopped()
      このグループのすべてのコンテナーが停止している場合は true を返します。
      戻り値:
      すべてが停止している場合は true。

    • addContainers

      public void addContainers(MessageListenerContainer... theContainers)
      1 つ以上のコンテナーをグループに追加します。
      パラメーター:
      theContainers - コンテナー。

    • removeContainer

      public boolean removeContainer(MessageListenerContainer container)
      グループからコンテナーを削除します。
      パラメーター:
      container - コンテナー。
      戻り値:
      コンテナーが削除された場合は true。

    • start

      public void start()
      次で指定:
      インターフェース Lifecycle の start 

    • stop

      public void stop()
      次で指定:
      インターフェース Lifecycle の stop 

    • isRunning

      public boolean isRunning()
      次で指定:
      インターフェース Lifecycle の isRunning 

    • toString

      public StringSE toString()
      オーバーライド:
      クラス ObjectSE の toString