ActiveMQ Artemis：通过选择器浏览消息但无法接收的问题分析与解决

import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory; // 注意：此依赖可能包含OpenWire
import javax.jms.*;
import java.util.Enumeration;

public class MessageReceiveFailureExample {

    public static void main(String[] args) throws JMSException {
        Connection connection = null;
        Session session = null;
        String messageIdToFind = "some-message-id"; // 假设这是之前发送消息的ID
        String selector = "JMSMessageID='" + messageIdToFind + "'";

        try {
            ConnectionFactory activeMQJMSConnectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
            connection = activeMQJMSConnectionFactory.createConnection();
            session = connection.createSession(true, Session.SESSION_TRANSACTED);
            Queue deadQueue = session.createQueue("hospital");
            connection.start();

            // 步骤1：使用QueueBrowser浏览消息
            // 假设此处能够成功找到一条消息
            QueueBrowser browser = session.createBrowser(deadQueue, selector);
            Enumeration e = browser.getEnumeration();
            int foundedElements = 0;
            while (e.hasMoreElements()) {
                Message message = (Message) e.nextElement();
                System.out.println("Browser found message with ID: " + message.getJMSMessageID());
                foundedElements++;
            }
            browser.close();

            if (foundedElements != 1) {
                throw new IllegalStateException("Browser did not find exactly one message.");
            }

            // 步骤2：尝试使用MessageConsumer接收消息
            // 在问题场景中，此处会返回null，导致抛出IllegalStateException
            MessageConsumer messageConsumer = session.createConsumer(deadQueue, selector);
            Message receivedMessage = messageConsumer.receive(1000); // 尝试接收消息，等待1秒

            if (receivedMessage == null) {
                throw new IllegalStateException("MessageConsumer failed to receive the message."); // 此处会抛出异常
            }
            System.out.println("MessageConsumer received message with ID: " + receivedMessage.getJMSMessageID());
            messageConsumer.close();

            session.commit();
            session.close();
        } catch (Exception e) {
            System.err.println("An error occurred: " + e.getMessage());
            try {
                if (session != null) {
                    session.rollback();
                    session.close();
                }
            } catch (JMSException e1) {
                e1.printStackTrace();
            }
            throw new RuntimeException(e);
        } finally {
            if (connection != null) {
                try {
                    connection.close();
                } catch (JMSException e) {
                    throw new RuntimeException(e);
                }
            }
        }
    }
}

<dependency>
    <groupId>org.apache.activemq</groupId>
    <artifactId>artemis-jms-client</artifactId>
    <version>2.18.0</version> <!-- 保持与Broker版本一致或略高于Broker版本 -->
</dependency>

import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory;
// ...
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");

import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory;
import javax.jms.*;
import java.