クラス BrokerEventListener
java.lang.ObjectSE
org.springframework.amqp.rabbit.core.BrokerEventListener
- 実装されたすべてのインターフェース:
MessageListener
、ConnectionListener
、Aware
、ApplicationEventPublisherAware
、Lifecycle
、Phased
、SmartLifecycle
public class BrokerEventListener
extends ObjectSE
implements MessageListener, ApplicationEventPublisherAware, ConnectionListener, SmartLifecycle
event-exchange-plugin が有効になっている場合 (この型のオブジェクトが Bean として宣言されている場合は https://www.rabbitmq.com/event-exchange.html), を参照)、選択されたイベントは
BrokerEvent
として発行されます。そのようなイベントは、ApplicationListener
または @EventListener
メソッドを使用して消費できます。AnonymousQueue
は提供されたキーで amq.rabbitmq.event
トピック交換にバインドされます。- 導入:
- 2.1
- 作成者:
- Gary Russell, Christian Tzolov
フィールドサマリー
インターフェース org.springframework.context.SmartLifecycle から継承されたフィールド
DEFAULT_PHASE
コンストラクターのサマリー
コンストラクターコンストラクター説明BrokerEventListener
(ConnectionFactory connectionFactory, StringSE... eventKeys) 提供された接続ファクトリとイベントキーを使用してインスタンスを構築します。BrokerEventListener
(AbstractMessageListenerContainer container, StringSE... eventKeys) 提供されたリスナーコンテナーファクトリとイベントキーを使用してインスタンスを構築します。メソッドのサマリー
修飾子と型メソッド説明キューをイベント交換にバインドしようとしたときにスローされた例外を返します。int
getPhase()
boolean
boolean
void
onCreate
(Connection connection) 新しい接続が確立されたときに呼び出されます。void
1 つのメッセージを配信します。void
setApplicationEventPublisher
(ApplicationEventPublisher applicationEventPublisher) void
setAutoStartup
(boolean autoStartup) void
setPhase
(int phase) void
start()
void
stop()
クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE
インターフェース org.springframework.amqp.rabbit.connection.ConnectionListener から継承されたメソッド
onClose, onFailed, onShutDown
インターフェース org.springframework.amqp.core.MessageListener から継承されたメソッド
containerAckMode, isAsyncReplies, onMessageBatch
インターフェース org.springframework.context.SmartLifecycle から継承されたメソッド
stop
コンストラクターの詳細
BrokerEventListener
提供された接続ファクトリとイベントキーを使用してインスタンスを構築します。イベントキーは、amq.rabbitmq.event
トピック交換に公開されたイベントのルーティングキーと一致するパターンです。ワイルドカードに一致する可能性があります。例はuser.#, queue.created
です。利用可能なイベントについては、プラグインのドキュメントを参照してください。シングルスレッドのDirectMessageListenerContainer
が作成されます。そのライフサイクルは、このオブジェクトのSmartLifecycle
メソッドによって制御されます。- パラメーター:
connectionFactory
- 接続ファクトリ。eventKeys
- イベントキー。
BrokerEventListener
提供されたリスナーコンテナーファクトリとイベントキーを使用してインスタンスを構築します。イベントキーは、amq.rabbitmq.event
トピック交換に公開されたイベントのルーティングキーと一致するパターンです。ワイルドカードに一致する可能性があります。例はuser.#, queue.created
です。利用可能なイベントについては、プラグインのドキュメントを参照してください。コンテナーのライフサイクルは、このオブジェクトのSmartLifecycle
メソッドによって制御されません。コンテナーは、キューまたはMessageListener
で構成しないでください。これらのプロパティは置き換えられます。- パラメーター:
container
- リスナーコンテナー。eventKeys
- イベントキー。
メソッドの詳細
setApplicationEventPublisher
- 次で指定:
- インターフェース
ApplicationEventPublisherAware
のsetApplicationEventPublisher
getBindingsFailedException
キューをイベント交換にバインドしようとしたときにスローされた例外を返します。- 戻り値:
- 例外。
start
public void start()stop
public void stop()isRunning
public boolean isRunning()getPhase
public int getPhase()- 次で指定:
- インターフェース
Phased
のgetPhase
- 次で指定:
- インターフェース
SmartLifecycle
のgetPhase
setPhase
public void setPhase(int phase) isAutoStartup
public boolean isAutoStartup()- 次で指定:
- インターフェース
SmartLifecycle
のisAutoStartup
setAutoStartup
public void setAutoStartup(boolean autoStartup) onMessage
インターフェースからコピーされた説明:MessageListener
1 つのメッセージを配信します。- 次で指定:
- インターフェース
MessageListener
のonMessage
- パラメーター:
message
- メッセージ。
onCreate
インターフェースからコピーされた説明:ConnectionListener
新しい接続が確立されたときに呼び出されます。- 次で指定:
- インターフェース
ConnectionListener
のonCreate
- パラメーター:
connection
- 接続。