Broker 事件监听器

当启用事件交换插件时，如果您向应用程序上下文添加一个 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) {
    ...
}