ActiveMQ 不从队列中取出消息

ActiveMQ Not Taking Messages off Queue

我最近将服务器从 ActiveMQ 从 5.8 升级到最新版本 (5.11.1)。从那时起,我偶尔会注意到消息会在特定队列上堆积而不会被删除。

我们的架构有一个生产者,一个消费者。我可以看到消费者仍然处于连接状态,但消息正在从生产者那里堆积起来。我的解决方案是通过 Web 控制台删除队列。之后,我立即看到消费者重新连接并再次开始处理消息。

如果相关,在这种情况下,生产者是 .NET 上的 运行 NMS,消费者是 Java 1.7 上的 运行 JMS。

当消费者连接到队列时,请从 Web 控制台检查队列中未提交的消息数。如果它大于零并且长时间没有变化,则表示您的消费者在读取输入消息时遇到问题。

如果上述情况属实,可能是因为生产者发送的文件不是 jms 投诉。

我最近 运行 在创建一个将所有消息从一个队列移动到另一个队列的实用程序时遇到了这个问题。

我可以看到我已连接到我的 AMQ 实例,我可以看到我创建的监听器,但它们不会从 Pending 移动到我的监听器...

我忘记在我的队列连接上调用 Start()。 :/