【问题标题】:Consumer Count / pending Message Count from Queue + ActiveMQ + Java来自队列 + ActiveMQ + Java 的消费者计数/待处理消息计数
【发布时间】:2015-12-13 11:10:34
【问题描述】:

我必须用 Java 开发实用程序,它将使用 ActiveMQ API 来获取队列/主题的属性,以获取消费者数量/待处理消息数量,还有什么方法可以从代码中删除任何消息排队?

【问题讨论】:

    标签: activemq spring-data-mongodb


    【解决方案1】:

    以下所有细节都是关于 ActiveMQ 的 Queue API,您也可以找到类似的主题内容

    • 使用getMessages().size() 可以找到没有待处理的消息
    • getConSumers().size()找不到消费者
    • 是的,我们可以从 Java 代码中删除消息到队列中,但是我们需要 MessageReferencemessageId 或合适的 message Selector 发生这种情况,你可以看看官方 removeMessage(...) 的文档和 removeMatchingMessages(...)here

    希望这会有所帮助!

    祝你好运!

    【讨论】:

      【解决方案2】:

      我建议使用Statistics Plugin 来获取消费者计数、待处理计数等。

      关于从队列中删除/删除任何特定消息,我建议不要在单独的程序中执行此操作,而让您的消息使用者处理此类消息。我认为这将是更易于维护的方法。

      【讨论】:

        猜你喜欢
        • 2011-12-08
        • 2022-01-14
        • 1970-01-01
        • 1970-01-01
        • 2014-06-27
        • 1970-01-01
        • 1970-01-01
        • 1970-01-01
        • 2013-06-09
        相关资源
        最近更新 更多