Artemis-如何避免非事务性会话的TransactionRolledBackException

Question

我使用Live/Backup和shared-storage并使用非事务JMS会话。我总是发送一条消息，我总是收到一条消息，然后确认，只有在第一次确认成功后才收到第二条消息。

Execution of JMS message listener failed. Caused by: [javax.jms.TransactionRolledBackException - AMQ219030: The transaction was rolled back on failover to a backup server]
javax.jms.TransactionRolledBackException: AMQ219030: The transaction was rolled back on failover to a backup server
        at org.apache.activemq.artemis.core.client.impl.ClientSessionImpl.rollbackOnFailover(ClientSessionImpl.java:904)
        at org.apache.activemq.artemis.core.client.impl.ClientSessionImpl.commit(ClientSessionImpl.java:927)
        at org.apache.activemq.artemis.jms.client.ActiveMQMessage.acknowledge(ActiveMQMessage.java:719)

1. 我使用Spring-JMS。使用者会话24/7工作（无限循环session.receive())
2. 主节点崩溃，然后重新启动主节点
3. 恢复后（几个小时后），我向队列发送了一条消息。使用者读取消息并在确认时抛出异常（因为标记为仅回滚）
4. 我再次阅读了邮件（这对我的任务来说并不是很糟糕），但重新传递计数没有增加
5. 我的消费者代码:

onMessage(Message message) {
  if (redeliveryCount(message) > 0){
    processAsDublicate(message);  // It's not invoked  - it is error in my business logic.
  }
}

问题：

如何避免非事务性会话的TransactionRolledBackException？如果这是不可能的，我应该改变消费者代码？

null

Answer 1

TransactionRolledBackException是预期的，如您在replicated-failback示例中所见。

为了防止使用者多次接收相同的消息，必须实现一个幂等使用者，ie Apache Camel提供了一个幂等使用者组件，可以与任何JMS提供者一起使用，请参见：http://Camel.Apache.org/idempotent-consumer.html