一次获取队列中的所有消息（Spring Boot JMSListerner注释）

Question

我有一个特殊的要求，即获取队列中所有挂起的消息，以便进一步处理它们。详细说明。这就是应用程序的流程：

• 有一个队列设置将承载消息
• 默认情况下，使用MessageListenerContainer的stop（）方法停止该队列的侦听器
• 将通过调用listenerContainer按需侦听队列中的消息。start（）
• 要求是我应该一次获取队列中可用的所有消息，以便只处理那些消息。如果由于任何原因，在处理现有消息期间，新消息被发布到队列上，那么这些消息应该保留在队列本身上。稍后当listenerContainer时，将再次读取这些内容。开始（） 按需调用

例如：

>

假设我们有一个名为abc queue的队列。JMS侦听器配置为：

@JmsListener(destination = "abc-queue", 
    containerFactory = "abcFactory",
    selector = "_type='java.util.LinkedHashMap'",
    id = "abc-listener")

在应用程序启动时，我们将这样做：

MessageListenerContainer listenerContainer = jmsListenerEndpointRegistry.getListenerContainer("abc-listener");
listenerContainer.stop();

应用程序将有一个控制器endpoint来按需监听此队列。一旦调用，就会发生以下情况：

MessageListenerContainer listenerContainer = jmsListenerEndpointRegistry.getListenerContainer("abc-listener");
listenerContainer.start();
// now read all the messages in queue at once and store them in a list
// listenerContainer.stop();
// start processing the messages one by one

问题：

• 我们如何一次读取所有消息并将其存储在列表中
• 即使队列中存在消息，listenerContainer。start（）不会立即开始处理队列。只有在队列上出现另一条消息后才会触发

任何有用的指针都将不胜感激。

Answer 1

潜在解决方案：

• 就像Daniel在评论中提到的那样，将消息移动到另一个队列
• 将消息从队列移动到文件
• 将消息从队列移动到数据库