代理事件监听器
当启用 事件交换插件 时,如果将类型为 BrokerEventListener
的 Bean 添加到应用程序上下文,它会将选定的代理事件发布为 BrokerEvent
实例,这些实例可以使用普通的 Spring ApplicationListener
或 @EventListener
方法进行消费。代理将事件发布到主题交换 amq.rabbitmq.event
,每个事件类型都有不同的路由键。监听器使用事件键,这些键用于将 AnonymousQueue
绑定到交换机,以便监听器仅接收选定的事件。由于它是一个主题交换机,因此可以使用通配符(以及显式请求特定事件),如下例所示
@Bean
public BrokerEventListener eventListener() {
return new BrokerEventListener(connectionFactory(), "user.deleted", "channel.#", "queue.#");
}
您可以通过使用普通的 Spring 技术进一步缩小各个事件监听器中接收的事件范围,如下例所示
@EventListener(condition = "event.eventType == 'queue.created'")
public void listener(BrokerEvent event) {
...
}