如何解决如何使用 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
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。