0

初始状态:兔子有一个消费者连接到它

事件:兔子和消费者之间的网络连接中断

结果:消费者试图重新连接 Rabbit,但 Rabbit 的消费者列表中有消费者

下一个事件:网络连接再次建立,消费者重新连接到兔子,但之前的兔子连接没有消失。

结果:兔子试图向不活跃的消费者发送消息

问题:是否有机会自动检查消费者是否仍然可用,如果没有 - 将其从列表中删除?

请注意,心跳选项已打开,但它不能解决问题。

connectionFactory.setRequestedHeartbeat(15);

使用的库是:使用的库 org.springframework.amqp:spring-rabbit:1.2.0.RELEASE com.rabbitmq:amqp-client:3.2.1

4

1 回答 1

1

什么版本?我刚刚使用 RabbitMQ 3.3.2 和 Spring-AMQP 1.3.4 进行了测试,一切都按预期工作。

于 2014-06-17T19:10:51.170 回答