Package org.springframework.amqp.rabbit.core

Class BrokerEventListener

java.lang.Object
org.springframework.amqp.rabbit.core.BrokerEventListener
All Implemented Interfaces:
MessageListener, ConnectionListener, Aware, ApplicationEventPublisherAware, Lifecycle, Phased, SmartLifecycle
public class BrokerEventListener extends Object implements MessageListener, ApplicationEventPublisherAware, ConnectionListener, SmartLifecycle
When the event-exchange-plugin is enabled (see https://www.rabbitmq.com/event-exchange.html), if an object of this type is declared as a bean, selected events will be published as BrokerEvents. Such events can then be consumed using an ApplicationListener or @EventListener method. An AnonymousQueue will be bound to the amq.rabbitmq.event topic exchange with the supplied keys.
Since:
2.1
Author:
Gary Russell, Christian Tzolov

  • Constructor Details

    • BrokerEventListener

      public BrokerEventListener(ConnectionFactory connectionFactory, String... eventKeys)
      Construct an instance using the supplied connection factory and event keys. Event keys are patterns to match routing keys for events published to the amq.rabbitmq.event topic exchange. They can therefore match wildcards; examples are user.#, queue.created. Refer to the plugin documentation for information about available events. A single-threaded DirectMessageListenerContainer will be created; its lifecycle will be controlled by this object's SmartLifecycle methods.
      Parameters:
      connectionFactory - the connection factory.
      eventKeys - the event keys.

    • BrokerEventListener

      public BrokerEventListener(AbstractMessageListenerContainer container, String... eventKeys)
      Construct an instance using the supplied listener container factory and event keys. Event keys are patterns to match routing keys for events published to the amq.rabbitmq.event topic exchange. They can therefore match wildcards; examples are user.#, queue.created. Refer to the plugin documentation for information about available events. The container's lifecycle will be not be controlled by this object's SmartLifecycle methods. The container should not be configured with queues or a MessageListener; those properties will be replaced.
      Parameters:
      container - the listener container.
      eventKeys - the event keys.

  • Method Details