ActiveMQ 如何检测慢消费者

Question

1. ActiveMQ 用来表示消费者速度慢的确切逻辑是什么 消费者？
2. 如果有多个消费者确实慢了考虑 其他消费者也连接到同一主题？

如果能提供相同的代码指针就太好了

Answer 1

1. 查看第100行和TopicSubscription.java中的add方法。

2. 慢速消费者是一种在接收已发布消息方面落后的慢速消费者。其他消费者有多“快”对于慢速消费者来说并不重要。更多的是生产消息和消费消息之间的区别。阅读代码以获取详细信息或将您的问题改写为更具体的内容。