使用 XASession 时消息未从 JMS 队列中删除

Question

我正在尝试连接到安慰队列并简单地从中读取消息。但是，我能够阅读消息，但消息没有从队列中删除。 以下是我尝试过的代码：

public void clearMessages() throws Exception {

        // Programmatically create the connection factory using default settings
        // Create connection to the Solace router

        SolXAConnectionFactoryImpl connectionFactory = returnConnFactory();


        XAConnection connection = connectionFactory.createXAConnection();

        XASession session = connection.createXASession();

        Queue queue = session.createQueue(QUEUE_NAME);
        connection.start();
        MessageConsumer messageConsumer = session.createConsumer(queue);
        //session.b

        messageConsumer.setMessageListener(new MessageListener() {
            @Override
            public void onMessage(Message message) {
                if(message instanceof SolTextMessage)  {
                    SolTextMessage solTextMessage =(SolTextMessage)message;
                    try {
                        System.out.println("Message cleared is : "+solTextMessage.getText());
                    } catch (JMSException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                }
                else {
                    System.out.println("Message Content: %s"+ SolJmsUtility.dumpMessage(message));
                }
                    latch.countDown(); 
            }
        });
        latch.await(120,TimeUnit.SECONDS);
        connection.stop();

        messageConsumer.close();
        session.close();
        connection.close();
    }

这里的latch是CountDownLatch的对象，初始化为：

CountDownLatch latch = new CountDownLatch(2);

Answer 1

您需要提交 XA 事务才能使用消息。 在JMS中，函数调用是XAResource.commit(xid, true)

另外，是否有使用 CountDownLatch 的理由？ 如果你想同步消费消息，可以选择不设置消息监听，调用MessageConsumer.receive()

Solace 确实提供了一个基本示例，展示了如何使用 XA 事务。 参考API示例目录下的XATransactions.java。

请注意，示例代码通过调用相关的 XAResource 方法（例如 XAResource.commit()）手动管理 XA 事务。 XA 事务通常在 Java EE 应用服务器中使用，其中包含一个事务管理器来管理 XA 事务的生命周期。