コンストラクターの詳細

• 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 - 接続。