java - 故障转移传输协议无法处理消费者控制消息

Question

作为 AbortSlowConsumerStrategy 的一部分，如果 Active MQ 发现消费者速度很慢，它会发送关闭消费者的命令，但在消费者/客户端，故障转移传输协议实现似乎无法处理此消费者控制命令，它失败说，“错误: 未知命令 - ConsumerControl.."; 有没有更好的方法来中止消费者而不是接收错误？

请注意，消费者在 DotNet 中使用 Apache.NMS 库。

Answer 1

听起来您正在使用不支持消费者控制的旧客户端库，新版本现在应该支持此功能。由于此JIRA 问题，此问题已在 5.12.0 中修复。

使用最新的客户端版本（最新版本是 5.14.4），您应该没有问题。

对于尚未进行这些修复的其他一些客户端库，您唯一的选择是将中止策略配置为仅终止具有慢速消费者的客户端的连接。此博客文章和API 文档中的一些信息信息。