当前位置: 首页 > 知识库问答 >
问题:

ActiveMQ:一条待处理消息但队列为空-ActiveMQ 5.12.0

钱展
2023-03-14

我有和这里描述的相同的问题:ActiveMQ:一条挂起的消息,但队列是空的。

  • 更多客户端:
    • 与hawtio-相同的行为
    • 我的java消费者
      • 不消耗任何东西
      • 重启后,继续消耗

      我们不将消息保存在默认的kaha db中,而是保存在Oracle DB中。我可以在表ACTIVEMQ_MSGS中看到数据库中的待处理消息。

      重新启动activeMQ后,所有客户端都按预期工作。在管理控制台中,我可以看到消息,java消费者使用了这些消息。

      通过对ActiveMQ 5.7.0的更新,解决了上述存在的问题。我检查了activeMQ日志,但没有发现错误或警告。消息的生产者也没有改变。

      知道我为什么会遇到这些问题吗?

共有1个答案

蒙才
2023-03-14

问题现在解决了。我还在活动的mq邮件列表中询问:http://activemq.2283324.n4.nabble.com/One-Pending-Message-but-Queue-is-empty-ActiveMQ-5-12-0-td4715720.html.

>

  • 首先,我们在客户端中添加了这个方法调用:

    org.apache.camel.ConsumerTemplate.doneUoW(Exchange exchange)
    

    但最终并没有解决问题

    • activeMQ中用于记录旧消息的队列太多

  •  类似资料:
    • 我对ActiveMQ有一个奇怪的问题。我有一个队列,似乎有一个挂起的消息,但当我打开队列时,没有消息。 这里怎么了?真的有消息等待处理吗?我怎样才能把信息带回来,或者至少能看到内容? 编辑:刚刚发现ActiveMQ 5.6.0的这两个错误。这可能是那个问题的根源吗? 不正确的报告挂起QueueSize的持久子后重新连接与未破解 OrderPendingList中的问题可能导致在持久子重新连接后无法

    • 环境/背景: 使用PHP Stomp库从ActiveMQ(v5.4.3)发送和接收消息。 步骤: 客户端发送消息并回复至 当没有挂起消息或挂起消息时,上述步骤可以正常工作 其他发现: > 允许在同一个请求队列中发送超过1000条消息(并最终处理并放置在响应队列中)。所以它看起来不像内存问题。 有趣的是,在等待超时时,如果我在管理UI上浏览队列,我会得到响应。 默认情况下,我使用的stomp代理将预

    • 我有两个消费者(不同的应用程序)连接到Azure队列。我可以或消息,在消费过程中,我可以或消息。裁判:http://msdn.microsoft.com/en-us/library/azure/hh851750.aspx. 我确定我想使用,然后消息,因为我希望它们在两个应用程序中被接收。我想我应该将队列上的消息生存期设置为10秒,作为删除机制。 然而,由于消息似乎在10秒钟后被删除,因此在这10秒

    • 我发送消息从JavaSpring Boot应用程序到消费者是Python应用程序。 除了输入命令rabbitmqctl list\u queues时,一切正常,它显示视频队列0,这意味着队列中没有消息。 消费者正在接收消息并执行一些长过程;所以如果我连续发送多条消息,应该会有一些消息在队列中等待。我说得对吗? 制片人: 消费者 在哪里可以看到我声明的队列上的消息?因为虽然我知道队列中有消息,但使用

    • 我正在尝试查看ActiveMQ(5.11.1)中队列中的所有消息。为此,我使用Hawtio(1.4.51)。我在ActiveMQ中的队列包含790条消息。 我的步骤到现在: 默认情况下,hawtio在ActiveMQ队列中最多显示400条消息。所以我去了我的broker.xml设置并添加了: 这给了我401条信息。 所以我尝试将maxBrowsePageSize=“401”更改为“-1”。令我惊讶

    • 这是关于一个特定的用例,我计划通过flink流来解决这个用例。 一个消息被发送到flink流处理,流被键控,从而得到预期的分区。然而,每个密钥的每个消息都需要评估,直到满足一个条件为止,例如,假设有一个银行系统,其中一个帐户的帐户交易(消息)需要按顺序处理,并且不可能处理不按顺序处理的消息,因为它将导致不一致的系统状态。系统需要等待一条消息被处理(甚至可能超过2-3天),然后再按顺序处理下一条消息