如何使用 SimpleRabbitListenerContainer 处理取消消费者

问题描述

考虑到未解决的问题 enter link description here，我想做一些与 handleCancel 相关的事情。

channel.queueDeclare(queue,false,true,null);
Consumer consumer = new DefaultConsumer(channel) {
@Override
public void handleCancel(String consumerTag) throws IOException {
    // consumer has been cancelled unexpectedly
}};

如何使用 SimpleRabbitListenerContainerFactory 做到这一点？

解决方法

为 @EventListener 添加 AsyncConsumerStoppedEvent。

https://docs.spring.io/spring-amqp/docs/current/reference/html/#consumer-events