パッケージ org.springframework.amqp.rabbit.core

クラス 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

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

    • BrokerEventListener

      public BrokerEventListener(ConnectionFactory connectionFactory, StringSE... eventKeys)
      提供された接続ファクトリとイベントキーを使用してインスタンスを構築します。イベントキーは、amq.rabbitmq.event トピック交換に公開されたイベントのルーティングキーと一致するパターンです。ワイルドカードに一致する可能性があります。例は user.#, queue.created です。利用可能なイベントについては、プラグインのドキュメントを参照してください。シングルスレッドの DirectMessageListenerContainer が作成されます。そのライフサイクルは、このオブジェクトの SmartLifecycle メソッドによって制御されます。
      パラメーター:
      connectionFactory - 接続ファクトリ。
      eventKeys - イベントキー。

    • BrokerEventListener

      public BrokerEventListener(AbstractMessageListenerContainer container, StringSE... eventKeys)
      提供されたリスナーコンテナーファクトリとイベントキーを使用してインスタンスを構築します。イベントキーは、amq.rabbitmq.event トピック交換に公開されたイベントのルーティングキーと一致するパターンです。ワイルドカードに一致する可能性があります。例は user.#, queue.created です。利用可能なイベントについては、プラグインのドキュメントを参照してください。コンテナーのライフサイクルは、このオブジェクトの SmartLifecycle メソッドによって制御されません。コンテナーは、キューまたは MessageListener で構成しないでください。これらのプロパティは置き換えられます。
      パラメーター:
      container - リスナーコンテナー。
      eventKeys - イベントキー。

  • メソッドの詳細

    • setApplicationEventPublisher

      public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
      次で指定:
      インターフェース ApplicationEventPublisherAware の setApplicationEventPublisher 

    • getBindingsFailedException

      @Nullable public ExceptionSE getBindingsFailedException()
      キューをイベント交換にバインドしようとしたときにスローされた例外を返します。
      戻り値:
      例外。

    • start

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

    • stop

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

    • isRunning

      public boolean isRunning()
      次で指定:
      インターフェース Lifecycle の 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

      public void onMessage(Message message)
      インターフェースからコピーされた説明: MessageListener
      1 つのメッセージを配信します。
      次で指定:
      インターフェース MessageListener の onMessage 
      パラメーター:
      message - メッセージ。

    • onCreate

      public void onCreate(@Nullable Connection connection)
      インターフェースからコピーされた説明: ConnectionListener
      新しい接続が確立されたときに呼び出されます。
      次で指定:
      インターフェース ConnectionListener の onCreate 
      パラメーター:
      connection - 接続。