初始状态:兔子有一个消费者连接到它
事件:兔子和消费者之间的网络连接中断
结果:消费者试图重新连接 Rabbit,但 Rabbit 的消费者列表中有消费者
下一个事件:网络连接再次建立,消费者重新连接到兔子,但之前的兔子连接没有消失。
结果:兔子试图向不活跃的消费者发送消息
问题:是否有机会自动检查消费者是否仍然可用,如果没有 - 将其从列表中删除?
请注意,心跳选项已打开,但它不能解决问题。
connectionFactory.setRequestedHeartbeat(15);
使用的库是:使用的库 org.springframework.amqp:spring-rabbit:1.2.0.RELEASE com.rabbitmq:amqp-client:3.2.1