【问题标题】:Durability Problem with ActiveMQ-cpp and stompActiveMQ-cpp 和 stomp 的持久性问题
【发布时间】:2011-05-29 20:24:09
【问题描述】:

我在使用 ActiveMQ-CPP 和 stomp 协议创建持久的消费者和生产者时遇到问题。我正在尝试使用 stomp 连接到 HornetQ,并且能够在非持久状态下发送和接收消息。 我尝试通过将其传递模式以及消息的 CMSDeliveryMode 设置为持久,并创建一个 DurableConsumer 而不是普通消费者,将生产者更改为持久。但是当我查看 JBoss JMX-Console 时,它​​们都被认为是非持久的(消息被归类为非持久的,消费者也被订阅为非持久的)。

我什至尝试了集成测试 StompDurableTest,但只收到了 20 条消息中的 10 条(消费者处于活动状态时发送的消息)。所以测试失败了。

由于集成测试不起作用,我猜它与 ActiveMQ-cpp 或 Stomp 配置有关,而不是代码。我是否缺少任何东西来启用耐用性?

提前致谢,

萨米

【问题讨论】:

    标签: c++ stomp hornetq activemq-cpp durability


    【解决方案1】:

    不确定 HornetMQ 的工作原理,但我看到其他人对目标名称有疑问,因为 hornet 不喜欢 CMS 为与 ActiveMQ 一起工作而附加的 /topic 和 /queue 前缀。

    需要注意的另一件事是,使用 Stomp,您的 clientId 和订阅 id 需要匹配,并且每次连接时都保持相同。

    问候 蒂姆

    www.fusesource.com

    【讨论】:

    • 感谢蒂姆的回复。我已经将 /queue/ 和 /topic/ 更改为 jms.queue。 & jms.topic。来自 ActiveMQ 源,并在持久性模式下将订阅名称设置为客户端 ID,但没有运气。当消费者处于活动状态时我可以成功接收,问题是当它被订阅而不是活动时。
    猜你喜欢
    • 1970-01-01
    • 2016-11-09
    • 2015-01-21
    • 2016-04-27
    • 2011-10-12
    • 2011-04-26
    • 1970-01-01
    • 2016-05-29
    • 1970-01-01
    相关资源
    最近更新 更多