我最近升级到 NMS ActiveMQ 1.5.2,当我重新启动代理时,连接和消费者得到恢复,但他们恢复到“拉”模式,这意味着代理不会自动向他们发送消息。这不是以前版本的行为方式。我需要的是让它恢复到原来的状态,即预取 1000。我想我一定是缺少故障转移 URL 或类似的设置。
这里有人知道我可以尝试什么吗?
我的堆栈是:
AMQ Broker 5.4.2
Spring.NET 1.3.2
Apache.NMS 1.5.0
Apache.NMS.ActiveMQ 1.5.2
(all the latest releases)
这是我在重新启动代理时看到的消费者日志条目:
restore consumer: ID:csi-dul-516m-6334-634583598187658753-1:0:-1:1 in pull mode pending recovery, overriding prefetch: 1000
restore consumer: ID:csi-dul-516m-6334-634583598187658753-1:0:-1:1
restore consumer: ID:csi-dul-516m-6334-634583598187658753-1:0:1:1 in pull mode pending
recovery, overriding prefetch: 1000
restore consumer: ID:csi-dul-516m-6334-634583598187658753-1:0:1:1
restore consumer: ID:csi-dul-516m-6334-634583598187658753-1:0:2:1 in pull mode pending
recovery, overriding prefetch: 1000
restore consumer: ID:csi-dul-516m-6334-634583598187658753-1:0:2:1
Sending queued commands...
Transport has resumed normal operation.
Connection established
Successfully reconnected to: tcp://localhost:61616/