activemq - 从队列中删除的消息

Question

我使用 BlockingQueue 实现通过队列中的服务处理我的事件。但是，如果服务器出现故障，则该队列中的所有事件都将被删除，因此我缺少要处理的事件。（我正在寻找一些内部数据库，服务器可以在其中存储来自队列的事件/消息，如果服务器再次关闭和启动，它可以加载所有事件/消息以再次处理，而无需手动干预）。

对此有任何帮助。我不确定是否应该使用 Apache ActiveMQ。我正在使用 apache servicemix。

提前致谢。

Answer 1

我无法回答如何使用 BlockingQueue 执行此操作。

但是 ActiveMQ 有两个特性可以让你受益：

持久队列，您可能还想查看持久队列

它有一个内置数据库，可以在后台执行此操作，并且即使代理或消费者必须重新启动，消息也可以保留在队列中。