在 ActiveMQ 中存储和处理消息

Posted

技术标签:

【中文标题】在 ActiveMQ 中存储和处理消息【英文标题】:Store and Process Messages in ActiveMQ 【发布时间】:2015-01-14 09:28:27 【问题描述】:

我已经使用 ActiveMQ 将我的消息发布给消费者,以便我可以在消费者端接收消息并触发一些东西。

现在我的问题是 ActiveMQ 可以支持存储和处理消息组吗?例如:

如果一次发布一组消息,我需要获取前两个并处理。其余的人应该排队等候。处理完这两条消息后,我需要处理另一条消息,直到处理完所选择的消息,其余消息应在队列中等待。

这可能吗?

【问题讨论】:

您是说要按特定顺序处理消息,还是在准备好之前不想处理其他消息? @ErikWilliams 在需要其他消息之前,我不想处理其他消息... 消息保留在队列中,除非您从队列中选择它们。我认为您需要更好地解释您的问题,以便我们了解您要解决的问题。 这是不可能的。消费者一次只能消费一条消息,一旦处理完毕,其他消息就会被拾取,依此类推.. 【参考方案1】:

You need to Subscribe the message after you completed your old processActiveMQ 将在您从队列中选择消息时将其送出。

【讨论】:

感谢您的回答。

以上是关于在 ActiveMQ 中存储和处理消息的主要内容,如果未能解决你的问题,请参考以下文章

JMS 之 Active MQ 消息存储

ActiveMQ---ActiveMQ原理分析之消息持久化

JMS 之 Active MQ 的消息传输

ActiveMQ 消息存储

初探active mq

SpringBoot 整合 ActiveMq