从 ActiveMq 中的队列中删除消息

Question

我有一个应用程序，有几个activeMq队列。我想列出其中的消息，并根据消息的 id 从任何队列中删除其中的任何消息。

这是我到目前为止的代码。

public void killMessage(String id) {
    try {
        ActiveMQConnection activeMqConnection = (ActiveMQConnection) connectionFactory.createConnection();
        activeMqConnection.start();
        DestinationSource destinationSource = activeMqConnection.getDestinationSource();
        Set<ActiveMQQueue> queues = destinationSource.getQueues();
        QueueSession queueSession = activeMqConnection.createQueueSession(true, Session.CLIENT_ACKNOWLEDGE);
        for(ActiveMQQueue queue : queues) {
            QueueBrowser browser = queueSession.createBrowser(queue);
            Enumeration<?> messagesInQueue = browser.getEnumeration();
            while (messagesInQueue.hasMoreElements()) {
                Message message = (Message) messagesInQueue.nextElement();
                System.out.println("Current id: " + message.getJMSMessageID());
                if(message.getJMSMessageID().equals(id)){
                    System.out.println("-----message id found-------");
                }
            }
        }
        activeMqConnection.close();
    } catch (JMSException e) {
        e.printStackTrace();
    }
}

我循环访问所有队列，然后循环访问每个队列中的所有消息。我什至找到了要删除的消息，但找不到将其从队列中删除的方法。

编辑：

我还创建了一个消费者。我不确定消费者应该如何使消息从队列中消失。我尝试这样做，根本没有效果，消息保留在队列中，我没有收到任何错误消息，也没有抛出可能表明消费者与消息不匹配的异常：

if(message.getJMSMessageID().equals(id)){
    System.out.println("-----message id found-------");
    MessageConsumer consumer = queueSession.createConsumer(queue, "JMSMessageID='" + id + "'");
    consumer.receive();
    consumer.close();
}

Answer 1

如果要使用

JMS API 执行此操作，则必须创建一个使用者并使用选择器来使用具有所需 ID 的消息。队列浏览器无法使用消息;它只能浏览它们。

在您粘贴的代码中，您正在创建一个事务处理会话，这意味着当您使用消息时，您需要提交会话，否则消息将永远不会被确认。也就是说，您最好改为使用 AUTO_ACKNOWLEDGE 创建一个非事务处理会话。

此外，您可能希望调用receive(int)(即超时(，以便如果选择器由于某种原因找不到消息，您的应用程序不会永远坐在那里等待方法返回。