故障转移传输协议无法处理消费者控制消息
Failover transport protocol can't handle consumercontrol messages
作为 AbortSlowConsumerStrategy 的一部分,如果 Active MQ 发现消费者速度较慢,它会向下发送一条关闭消费者的命令,但在 consumer/client 端,故障转移传输协议实现似乎无法处理此 Consumercontrol 命令, 它没有说 "ERROR: Unknown Command - ConsumerControl..";有没有更好的方法来中止消费者而不是接收错误?
请注意,消费者在 DotNet 中使用 Apache.NMS 库。
听起来您使用的是不支持消费者控制的旧客户端库,较新的版本现在应该支持此功能。由于此 JIRA issue.
,此问题已在 5.12.0 中修复
使用最新的客户端版本(最新版本是 5.14.4),您应该不会有问题。
对于尚未进行这些修复的其他一些客户端库,您唯一的选择是配置中止策略以仅终止具有慢速消费者的客户端的连接。 blog post and the API docs.
中的一些信息信息
作为 AbortSlowConsumerStrategy 的一部分,如果 Active MQ 发现消费者速度较慢,它会向下发送一条关闭消费者的命令,但在 consumer/client 端,故障转移传输协议实现似乎无法处理此 Consumercontrol 命令, 它没有说 "ERROR: Unknown Command - ConsumerControl..";有没有更好的方法来中止消费者而不是接收错误?
请注意,消费者在 DotNet 中使用 Apache.NMS 库。
听起来您使用的是不支持消费者控制的旧客户端库,较新的版本现在应该支持此功能。由于此 JIRA issue.
,此问题已在 5.12.0 中修复使用最新的客户端版本(最新版本是 5.14.4),您应该不会有问题。
对于尚未进行这些修复的其他一些客户端库,您唯一的选择是配置中止策略以仅终止具有慢速消费者的客户端的连接。 blog post and the API docs.
中的一些信息信息