Artemis-如何避免非事务性会话的TransactionRolledBackException
我使用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)
- 我使用Spring-JMS。使用者会话24/7工作（无限循环
session.receive()) - 主节点崩溃，然后重新启动主节点
- 恢复后（几个小时后），我向队列发送了一条消息。使用者读取消息并在确认时抛出异常（因为标记为仅回滚）
- 我再次阅读了邮件（这对我的任务来说并不是很糟糕），但重新传递计数没有增加
- 我的消费者代码:
onMessage(Message message) {
if (redeliveryCount(message) > 0){
processAsDublicate(message); // It's not invoked - it is error in my business logic.
}
}
问题：
如何避免非事务性会话的TransactionRolledBackException？如果这是不可能的，我应该改变消费者代码？
-
null
共有1个答案
TransactionRolledBackException是预期的，如您在replicated-failback示例中所见。
为了防止使用者多次接收相同的消息，必须实现一个幂等使用者，ie Apache Camel提供了一个幂等使用者组件，可以与任何JMS提供者一起使用，请参见：http://Camel.Apache.org/idempotent-consumer.html
-
问题内容： 我需要确保许多并发用户能够访问数据库。虽然在每次提交后我都关闭了会话，但是有时我的代码遇到以下错误，但是当我几次执行相同的操作时，它会超过错误并可以正常工作。 我的hibernate状态是4.2.1。 我的密码 HibernateUtil 组态 问题答案： 在您的“我的代码”代码段中，可能存在一些问题： 发生异常时，没有阻止关闭会话的块 您正在打电话，但这与有所不同。因此，不会清除。
-
你好，我有一个基于spring boot的后端，我们正在使用自己的库将JPA实体转换为DTO的（库基于反射工作）。问题是，我们将服务层直接注入到一些映射器中。假设我有一个和。UserDto有一个名为avatar的字段，化身存储在中。因此，为了构建UserDto，我们使用如下代码。 我不喜欢这种方法，因为Mapper必须对服务层一无所知。但是，这个映射器也被其他映射器使用。如果我想返回一个Order
-
我对Hibernate中的会话和事务的概念有点困惑。据我所知，Hibernate使用会话（持久性上下文），它基本上是需要持久，删除或数据库中任何内容的实体的缓存。会话封装事务，因此我启动一个会话，然后创建一个事务。事务关闭后，持久性上下文中的所有内容都将刷新到数据库，如果我关闭会话，也会发生同样的事情。 为什么我需要两者？我可以在不创建交易的情况下做同样的事情吗？
-
问题内容： 我正在尝试通过从客户端向服务器发送密钥和随机数来认证用户。 我的代码未向我显示客户端的响应。执行下面的代码时，我得到了一个空指针异常。 问题答案： 解决大多数问题的固定步骤： 阅读堆栈跟踪以确定哪一行代码引发NPE 在该行代码处设置一个断点 使用调试器，在遇到断点时，确定该行中的对象引用是 弄清楚为什么引用该文件（到目前为止，这是唯一实际的困难部分） 解决根本原因（也可能很困难）
-
问题内容： 我有两个简单的Java代码。第一个将恒定功率定义为power = a.pow（b）; 第二个将恒定功率定义为power = BigInteger.ONE.shiftLeft（b） 在命令行中设置内存标志- Xmx1024m，第一个代码可以正常工作，但是第二个代码却出现错误：java.lang.OutOfMemoryError：Java堆空间 我的问题：我应该在第二个代码中更改什么以避免
-
问题内容： 我有一个用于将文本添加到现有.doc文件中的代码，它将通过使用apache POI将其另存为另一个名称。 以下是到目前为止我尝试过的代码 以下是我得到的 我已经添加了与此对应的所有jar文件，但仍然找不到解决方案。我对apache poi是陌生的，所以请帮我提供一些解释和示例。谢谢 问题答案： 从我对问题的评论中复制： 看起来您需要Apache POI发行版中的poi-ooxml-sc