ActiveMQ Artemis：选择器浏览成功但消费者接收失败的解决方案

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

public class MessageReceiveFailureReproducer {

    private static final String BROKER_URL = "tcp://localhost:61616";
    private static final String QUEUE_NAME = "hospital";

    public static void main(String[] args) {
        // 假设 'id' 是通过某种方式获取到的消息ID
        String messageIdToFind = "some-message-id-example"; // 替换为实际的消息ID
        String selector = "JMSMessageID='" + messageIdToFind + "'";

        Connection connection = null;
        Session session = null;

        try {
            ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(BROKER_URL);
            connection = connectionFactory.createConnection();
            session = connection.createSession(true, Session.SESSION_TRANSACTED);
            Queue deadQueue = session.createQueue(QUEUE_NAME);
            connection.start();

            // 1. 使用 QueueBrowser 浏览消息
            QueueBrowser browser = session.createBrowser(deadQueue, selector);
            Enumeration<?> enumeration = browser.getEnumeration();
            int foundedElements = 0;
            while (enumeration.hasMoreElements()) {
                Message message = (Message) enumeration.nextElement();
                System.out.println("Browser found message with ID: " + message.getJMSMessageID());
                foundedElements++;
            }
            browser.close();

            if (foundedElements != 1) {
                throw new IllegalStateException("Expected 1 message with selector, but found " + foundedElements);
            }

            // 2. 使用 MessageConsumer 尝试接收消息
            MessageConsumer messageConsumer = session.createConsumer(deadQueue, selector);
            Message receivedMessage = messageConsumer.receive(1000); // 设置超时1秒

            if (receivedMessage == null) {
                throw new IllegalStateException("MessageConsumer failed to receive message with ID: " + messageIdToFind);
            } else {
                System.out.println("Consumer successfully received message with ID: " + receivedMessage.getJMSMessageID());
            }
            messageConsumer.close();

            session.commit(); // 提交事务
            System.out.println("Transaction committed successfully.");

        } catch (JMSException | RuntimeException e) {
            System.err.println("An error occurred: " + e.getMessage());
            try {
                if (session != null) {
                    session.rollback(); // 回滚事务
                    System.out.println("Transaction rolled back.");
                }
            } catch (JMSException e1) {
                System.err.println("Error during rollback: " + e1.getMessage());
            }
            throw new RuntimeException("Application failed", e);
        } finally {
            if (session != null) {
                try {
                    session.close();
                } catch (JMSException e) {
                    System.err.println("Error closing session: " + e.getMessage());
                }
            }
            if (connection != null) {
                try {
                    connection.close();
                } catch (JMSException e) {
                    System.err.println("Error closing connection: " + e.getMessage());
                }
            }
        }
    }
}

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

public class CoreJMSClientExample {

    private static final String BROKER_URL = "tcp://localhost:61616";
    private static final String QUEUE_NAME = "hospital";
    private static final String TEST_MESSAGE_CONTENT = "This is a test message for Artemis.";

    public static void main(String[] args) {
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(BROKER_URL);

        try (Connection connection = connectionFactory.createConnection()) {
            Session session = connection.createSession(true, Session.SESSION_TRANSACTED);
            Queue deadQueue = session.createQueue(QUEUE_NAME);
            connection.start();

            // 1. 发送一条带特定内容的测试消息
            MessageProducer producer = session.createProducer(deadQueue);
            TextMessage sentMessage = session.createTextMessage(TEST_MESSAGE_CONTENT);
            producer.send(sentMessage);
            session.commit(); // 提交发送事务

            String sentMessageId = sentMessage.getJMSMessageID();
            String selector = "JMSMessageID='" + sentMessageId + "'";
            System.out.println("Sent message with ID: " + sentMessageId);
            System.out.println("Using selector: " + selector);

            // 2. 使用 QueueBrowser 浏览消息
            QueueBrowser browser = session.createBrowser(deadQueue, selector);
            Enumeration<?> enumeration = browser.getEnumeration();
            int foundedElements = 0;
            while (enumeration.hasMoreElements()) {
                Message msg = (Message) enumeration.nextElement();
                System.out.println("Browser found message with ID: " + msg.getJMSMessageID());
                foundedElements++;
            }
            browser.close();

            if (foundedElements != 1) {
                throw new IllegalStateException("Expected 1 message with selector, but browser found " + foundedElements);
            }

            // 3. 使用 MessageConsumer 接收消息
            MessageConsumer consumer = session.createConsumer(deadQueue, selector);
            Message receivedMessage = consumer.receive(5000); // 5秒超时

            if (receivedMessage == null) {
                throw new IllegalStateException("MessageConsumer failed to receive message with ID: " + sentMessageId);
            } else if (!(receivedMessage instanceof TextMessage) || !((TextMessage) receivedMessage).getText().equals(TEST_MESSAGE_CONTENT)) {
                throw new IllegalStateException("Received message content does not match or is not a TextMessage.");
            }
            System.out.println("Consumer successfully received message with ID: " + receivedMessage.getJMSMessageID() + 
                               " Content: " + ((TextMessage) receivedMessage).getText());
            consumer.close();

            session.commit(); // 提交接收事务
            System.out.println("Transaction committed successfully after receiving.");

        } catch (JMSException e) {
            System.err.println("JMS Exception occurred: " + e.getMessage());
            throw new RuntimeException("JMS operation failed", e);
        } catch (Exception e) {
            System.err.println("An unexpected error occurred: " + e.getMessage());
            throw new RuntimeException("Application failed", e);
        }
    }
}

<dependency>
    <groupId>org.apache.activemq</groupId>
    <artifactId>artemis-jms-client</artifactId>
    <version>2.18.0</version> <!-- 与您的Broker版本匹配或更高 -->
</dependency>