クラス RabbitListenerEndpointRegistry
- java.lang.ObjectSE
-
- org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry
- 実装されたすべてのインターフェース:
EventListenerSE
、Aware
、DisposableBean
、ApplicationContextAware
、ApplicationListener<ContextRefreshedEvent>
、Lifecycle
、Phased
、SmartLifecycle
public class RabbitListenerEndpointRegistry extends ObjectSE implements DisposableBean, SmartLifecycle, ApplicationContextAware, ApplicationListener<ContextRefreshedEvent>
登録されたエンドポイントに必要なMessageListenerContainer
インスタンスを作成します。また、特にアプリケーションコンテキストのライフサイクル内で、リスナーコンテナーのライフサイクルを管理します。手動で作成された
MessageListenerContainer
とは異なり、レジストリによって管理されるリスナーコンテナーは、アプリケーションコンテキストでは Bean ではなく、オートワイヤーの候補にもなりません。管理目的でこのレジストリのリスナーコンテナーにアクセスする必要がある場合は、getListenerContainers()
を使用します。特定のメッセージリスナーコンテナーにアクセスする必要がある場合は、エンドポイントの ID を指定してgetListenerContainer(String)
を使用します。- 導入:
- 1.4
- 作成者:
- Stephane Nicoll, Juergen Hoeller, Artem Bilan, Gary Russell
- 関連事項:
RabbitListenerEndpoint
,MessageListenerContainer
,RabbitListenerContainerFactory
フィールドサマリー
フィールド 修飾子と型 フィールド 説明 protected Log
logger
インターフェース org.springframework.context.SmartLifecycle から継承されたフィールド
DEFAULT_PHASE
コンストラクターのサマリー
コンストラクター コンストラクター 説明 RabbitListenerEndpointRegistry()
メソッドのサマリー
フィールドの詳細
logger
protected final Log logger
メソッドの詳細
setApplicationContext
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException
- 次で指定:
- インターフェース
ApplicationContextAware
のsetApplicationContext
- 例外:
BeansException
getListenerContainer
public MessageListenerContainer getListenerContainer(StringSE id)
指定された ID を持つMessageListenerContainer
またはそのようなコンテナーが存在しない場合はnull
を返します。- パラメーター:
id
- コンテナーの ID- 戻り値:
- コンテナー、またはその ID のコンテナーが存在しない場合は
null
- 関連事項:
RabbitListenerEndpoint.getId()
,getListenerContainerIds()
getListenerContainerIds
public SetSE<StringSE> getListenerContainerIds()
マネージドMessageListenerContainer
インスタンスの ID を返します。- 戻り値:
- ID。
- 導入:
- 1.5.2
- 関連事項:
getListenerContainer(String)
getListenerContainers
public CollectionSE<MessageListenerContainer> getListenerContainers()
- 戻り値:
- 管理対象の
MessageListenerContainer
インスタンス。
registerListenerContainer
public void registerListenerContainer(RabbitListenerEndpoint endpoint, RabbitListenerContainerFactory<?> factory)
指定されたRabbitListenerEndpoint
のメッセージリスナーコンテナーを作成します。これにより、構成に関してエンドポイントを尊重するために必要なインフラストラクチャが作成されます。
- パラメーター:
endpoint
- 追加するエンドポイントfactory
- 使用するリスナーファクトリ- 関連事項:
registerListenerContainer(RabbitListenerEndpoint, RabbitListenerContainerFactory, boolean)
registerListenerContainer
public void registerListenerContainer(RabbitListenerEndpoint endpoint, RabbitListenerContainerFactory<?> factory, boolean startImmediately)
指定されたRabbitListenerEndpoint
のメッセージリスナーコンテナーを作成します。これにより、構成に関してエンドポイントを尊重するために必要なインフラストラクチャが作成されます。
startImmediately
フラグは、コンテナーをすぐに開始する必要があるかどうかを決定します。- パラメーター:
endpoint
- 追加するエンドポイント。factory
- 使用するRabbitListenerContainerFactory
。startImmediately
- 必要に応じてすぐにコンテナーを開始します- 関連事項:
getListenerContainers()
,getListenerContainer(String)
createListenerContainer
protected MessageListenerContainer createListenerContainer(RabbitListenerEndpoint endpoint, RabbitListenerContainerFactory<?> factory)
指定されたファクトリを使用して、新しいMessageListenerContainer
を作成して開始します。- パラメーター:
endpoint
-MessageListenerContainer
を作成するためのエンドポイント。factory
- 使用するRabbitListenerContainerFactory
。- 戻り値:
MessageListenerContainer
unregisterListenerContainer
@Nullable public MessageListenerContainer unregisterListenerContainer(StringSE id)
レジストリからリスナーコンテナーを削除します。- パラメーター:
id
- コンテナー ID。- 戻り値:
- ID に一致する登録がない場合は null。
- 導入:
- 2.0.6
destroy
public void destroy()
- 次で指定:
- インターフェース
DisposableBean
のdestroy
getPhase
public int getPhase()
- 次で指定:
- インターフェース
Phased
のgetPhase
- 次で指定:
- インターフェース
SmartLifecycle
のgetPhase
isAutoStartup
public boolean isAutoStartup()
- 次で指定:
- インターフェース
SmartLifecycle
のisAutoStartup
stop
public void stop(RunnableSE callback)
- 次で指定:
- インターフェース
SmartLifecycle
のstop
onApplicationEvent
public void onApplicationEvent(ContextRefreshedEvent event)
- 次で指定:
- インターフェース
ApplicationListener<ContextRefreshedEvent>
のonApplicationEvent