クラス KafkaListenerEndpointRegistry

メソッドの詳細

• setApplicationContext

  public void setApplicationContext(ApplicationContext applicationContext) throws BeansException

  次で指定:

  インターフェース ApplicationContextAware の setApplicationContext 

  例外:

  BeansException

• getListenerContainer

  @Nullable public MessageListenerContainer getListenerContainer(StringSE id)

  指定された ID を持つ MessageListenerContainer またはそのようなコンテナーが存在しない場合は null を返します。

  次で指定:

  インターフェース ListenerContainerRegistry の getListenerContainer 

  パラメーター:

  id - コンテナーの ID

  戻り値:

  コンテナー、またはその ID のコンテナーが存在しない場合は null 

  関連事項:

  • KafkaListenerEndpoint.getId()
  • getListenerContainerIds()

• getListenerContainersMatching

  public CollectionSE<MessageListenerContainer> getListenerContainersMatching(PredicateSE<StringSE> idMatcher)

  述語に一致する ID を持つすべての MessageListenerContainer インスタンスを返します。そのようなコンテナーが存在しない場合は空の CollectionSE を返します。

  次で指定:

  インターフェース ListenerContainerRegistry の getListenerContainersMatching 

  パラメーター:

  idMatcher - コンテナー ID と一致する述語

  戻り値:

  コンテナー、または、その ID のコンテナーが存在しない場合は空の CollectionSE

  導入:

  3.2

  関連事項:

  • getListenerContainerIds()
  • getListenerContainer(String)

• getListenerContainersMatching

  public CollectionSE<MessageListenerContainer> getListenerContainersMatching(BiPredicateSE<StringSE,MessageListenerContainer> idAndContainerMatcher)

  指定された双述語を満たすすべての MessageListenerContainer インスタンスを返します。BiPredicate<String, MessageListenerContainer> は、コンテナー ID とコンテナー自体を引数として受け取ります。これにより、コンテナー自体のプロパティや状態など、より高度なフィルタリングが可能になります。

  次で指定:

  インターフェース ListenerContainerRegistry の getListenerContainersMatching 

  パラメーター:

  idAndContainerMatcher - コンテナー ID とコンテナーを一致させるための双述語

  戻り値:

  双述語条件に一致するコンテナー、または一致するコンテナーが存在しない場合は空の CollectionSE

  導入:

  3.2

  関連事項:

  • getListenerContainerIds()
  • getListenerContainersMatching(Predicate)

• getUnregisteredListenerContainer

  @Nullable public MessageListenerContainer getUnregisteredListenerContainer(StringSE id)

  インターフェースからコピーされた説明: ListenerContainerRegistry

  指定された ID を持つ MessageListenerContainer を返すか、そのようなコンテナーが存在しない場合は null を返します。レジストリに登録されていないが、アプリケーションコンテキストに存在するコンテナーを返します。

  次で指定:

  インターフェース ListenerContainerRegistry の getUnregisteredListenerContainer 

  パラメーター:

  id - コンテナーの ID

  戻り値:

  コンテナー、またはその ID のコンテナーが存在しない場合は null 

  関連事項:

  • ListenerContainerRegistry.getListenerContainerIds()

• setAlwaysStartAfterRefresh

  public void setAlwaysStartAfterRefresh(boolean alwaysStartAfterRefresh)

  By default, containers registered for endpoints after the context is refreshed are immediately started, regardless of their autoStartup property, to comply with the SmartLifecycle contract, where autoStartup is only considered during context initialization. Set to false to apply the autoStartup property, even for late endpoint binding. If this is called after the context is refreshed, it will apply to any endpoints registered after that call.

  パラメーター:

  alwaysStartAfterRefresh - プロパティを適用するには false。

  導入:

  2.8.7

• getListenerContainerIds

  public SetSE<StringSE> getListenerContainerIds()

  マネージド MessageListenerContainer インスタンスの ID を返します。

  次で指定:

  インターフェース ListenerContainerRegistry の getListenerContainerIds 

  戻り値:

  ID。

  関連事項:

  • getListenerContainer(String)

• getListenerContainers

  public CollectionSE<MessageListenerContainer> getListenerContainers()

  マネージド MessageListenerContainer インスタンスを返します。

  次で指定:

  インターフェース ListenerContainerRegistry の getListenerContainers 

  戻り値:

  管理対象の MessageListenerContainer インスタンス。

  関連事項:

  • getAllListenerContainers()

• getAllListenerContainers

  public CollectionSE<MessageListenerContainer> getAllListenerContainers()

  このレジストリによって管理されているインスタンスと、アプリケーションコンテキストで Bean として宣言されているインスタンスを含むすべての MessageListenerContainer インスタンスを返します。プロトタイプスコープのコンテナーが含まれます。まだ作成されていないレイジー Bean は、このメソッドの呼び出しによって初期化されません。

  次で指定:

  インターフェース ListenerContainerRegistry の getAllListenerContainers 

  戻り値:

  MessageListenerContainer インスタンス。

  導入:

  2.2.5

  関連事項:

  • getListenerContainers()

• registerListenerContainer

  public void registerListenerContainer(KafkaListenerEndpoint endpoint, KafkaListenerContainerFactory<?> factory)

  指定された KafkaListenerEndpoint のメッセージリスナーコンテナーを作成します。

  これにより、構成に関してエンドポイントを尊重するために必要なインフラストラクチャが作成されます。

  パラメーター:

  endpoint - 追加するエンドポイント

  factory - 使用するリスナーファクトリ

  関連事項:

  • registerListenerContainer(KafkaListenerEndpoint, KafkaListenerContainerFactory, boolean)

• registerListenerContainer

  public void registerListenerContainer(KafkaListenerEndpoint endpoint, KafkaListenerContainerFactory<?> factory, boolean startImmediately)

  指定された KafkaListenerEndpoint のメッセージリスナーコンテナーを作成します。

  これにより、構成に関してエンドポイントを尊重するために必要なインフラストラクチャが作成されます。

  startImmediately フラグは、コンテナーをすぐに開始する必要があるかどうかを決定します。

  パラメーター:

  endpoint - 追加するエンドポイント。

  factory - 使用する KafkaListenerContainerFactory。

  startImmediately - 必要に応じてすぐにコンテナーを開始します

  関連事項:

  • getListenerContainers()
  • getListenerContainer(String)

• unregisterListenerContainer

  @Nullable public MessageListenerContainer unregisterListenerContainer(StringSE id)

  指定された ID でリスナーコンテナーを登録解除します。

  IMPORTANT: このメソッドは、レジストリからコンテナーを削除するだけです。Lifecycle または DisposableBean メソッドを呼び出しません。コンテナーをシャットダウンするには、このメソッドを呼び出す前または後に呼び出す必要があります。

  パラメーター:

  id - ID。

  戻り値:

  コンテナー (登録されている場合)。それ以外の場合は null。

  導入:

  2.8.9

• createListenerContainer

  protected MessageListenerContainer createListenerContainer(KafkaListenerEndpoint endpoint, KafkaListenerContainerFactory<?> factory)

  指定されたファクトリを使用して、新しい MessageListenerContainer を作成して開始します。

  パラメーター:

  endpoint - MessageListenerContainer を作成するためのエンドポイント。

  factory - 使用する KafkaListenerContainerFactory。

  戻り値:

  MessageListenerContainer

• destroy

  public void destroy()

  次で指定:

  インターフェース DisposableBean の destroy 

• getPhase

  public int getPhase()

  次で指定:

  インターフェース Phased の getPhase 

  次で指定:

  インターフェース SmartLifecycle の getPhase 

• start

  public void start()

  次で指定:

  インターフェース Lifecycle の start 

• stop

  public void stop()

  次で指定:

  インターフェース Lifecycle の stop 

• stop

  public void stop(RunnableSE callback)

  次で指定:

  インターフェース SmartLifecycle の stop 

• isRunning

  public boolean isRunning()

  次で指定:

  インターフェース Lifecycle の isRunning 

• onApplicationEvent

  public void onApplicationEvent(ContextRefreshedEvent event)

  次で指定:

  インターフェース ApplicationListener<ContextRefreshedEvent> の onApplicationEvent