如何使用Camel Jms事务回滚回滚OracleDB提交
Camel Jms是一个用于集成消息传递系统的开源框架，它提供了一种简化的方式来处理消息的发送和接收。在使用Camel Jms时，如果需要在发送或接收消息的过程中进行事务管理，并且在出现异常时回滚事务并回滚Oracle数据库的提交，可以按照以下步骤进行操作：
- 配置Jms组件：首先，需要在Camel配置文件中配置Jms组件，指定连接工厂、目标队列等相关信息。例如：
<bean id="jmsConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://localhost:61616" />
</bean>
<bean id="jms" class="org.apache.camel.component.jms.JmsComponent">
<property name="connectionFactory" ref="jmsConnectionFactory" />
</bean>- 配置事务管理器：接下来，需要配置事务管理器，以便在发送或接收消息时进行事务管理。例如，可以使用Spring的JtaTransactionManager：
<bean id="transactionManager" class="org.springframework.transaction.jta.JtaTransactionManager">
<property name="userTransaction" ref="userTransaction" />
<property name="transactionManager" ref="transactionManager" />
</bean>- 配置路由：在Camel路由中，使用
transacted关键字来启用事务管理，并在需要进行事务回滚的地方使用rollback关键字。例如：
from("jms:queue:inputQueue")
.transacted()
.process(new MyProcessor())
.to("jms:queue:outputQueue")
.rollback();在上述示例中，transacted()方法启用了事务管理，rollback()方法表示在出现异常时回滚事务。
- 处理异常：为了能够捕获并处理异常，可以在路由中使用
onException关键字。例如：
onException(Exception.class)
.handled(true)
.process(new MyExceptionHandler())
.rollback();在上述示例中，onException(Exception.class)表示捕获所有类型的异常，handled(true)表示由异常处理器处理异常，rollback()表示在处理异常后回滚事务。
需要注意的是，以上步骤中的示例代码仅供参考，实际使用时需要根据具体的业务需求进行适当的修改和调整。
关于Camel Jms的更多信息和使用方法，可以参考腾讯云的相关产品和文档：
- Camel Jms：腾讯云提供的Camel Jms产品介绍和文档。
- 消息队列（TDMQ）：腾讯云提供的消息队列（TDMQ）产品，可用于集成消息传递系统。
- 云数据库 Oracle：腾讯云提供的云数据库 Oracle产品，可用于存储和管理数据。
相关·内容
我正在使用Apache camel 3.1.0和Spring boot 1.5.6，我已经成功地创建了完美工作的Camel事务路由。myDaoImplClass.myTransactionalDatabaseMethod("Save data coming in Message")
).to(Destination Endpoint) 当目标队列上的队列深度变满，并且由于事务路由而未将其从源队列中删除时有没有一种方法可以回滚持久化数据，或者只在整个路
浏览 12提问于2020-11-25得票数 0
然后，我查看了，看起来您可以设置一个maximumRedeliveries来再次处理队列消息，所以在失败的情况下回滚事务，我想知道在同一条骆驼路由中，如果我们必须调用REST服务来发布某件东西，该部分如何回滚假设在start-somethingelse中出现异常，REST post调用如何进行回滚？因为我们以无状态的方式调用外部服务。
浏览 0提问于2018-11-20得票数 0
回答已采纳
在PostgreSql中回滚的意义是什么，以及何时使用它？现在我不明白为什么有人会想要写一笔交易，然后含蓄地坚持要终止它？在我看来，没有人应该使
浏览 1提问于2020-05-05得票数 1
回答已采纳
1回答
我正在调查运行在ServiceMix (v4.4.2)中的骆驼事务。以下是我的路线：.transacted("PROPAGATION_REQUIRED" class="org.apache.camel.component.jms.JmsComponent">
浏览 0提问于2012-09-17得票数 1
回答已采纳
1回答
我有一个oracle数据库插入操作运行在同一个事务中，如果事务回滚，它将回滚更改。卡夫卡生产者在交易回滚的情况下是如何表现的？注意:生产者代码是使用spring引导编
浏览 2提问于2021-05-21得票数 0
1回答
我正在编写一个Camel应用程序(在ServiceMix v4.4.2中运行)，它需要能够处理异常(使用死信队列存储消息以便稍后重试)，并且能够在硬件死机时从中断的地方重新开始。我认为我需要事务和错误处理程序的混合，但不确定如何开始。
任何相关教程的建议或指针都会很棒。
浏览 2提问于2012-09-17得票数 2
回答已采纳
所以我不知道他们有没有开始交易.即使我要求用户启动一个事务来使用我的SP，我仍然对Save Points的正确使用有疑问。我尝试了COMMIT TRANSACTION MySavePointName，但是调用者尝试提交它的事务并得到一个错误：
提交事务请求没有相应的BEGIN事务。因此，我想知道-一个保存点可以回滚(这是可行的：ROLLBACK TRANSACTION MySavePointName不会回</
浏览 11提问于2012-03-15得票数 20
回答已采纳
我编写了这个用于教育apache camel事务的代码。throw new Exception(); .end(); })我在文档中发现这种配置<bean id="jmstx" class
浏览 1提问于2019-08-27得票数 0
1回答
如果camel DSL被标记为transacted()，那么我们真的需要在Spring服务方法中添加@Transactional注释吗？
我真的很想知道骆驼和Spring之间的事务交互。
浏览 0提问于2019-03-20得票数 1
回答已采纳
1回答
JMS从同步到异步
、、、
我能够使用JMS创建同步服务总线，但无法将其转换为异步服务总线。我试图异步地向服务发送请求，因此如果服务关闭，我希望JMS队列保留请求消息，当服务启动时，它将消息传递给服务并返回响应。这是我的密码 <route >
<fromlevel=INFO"><b
浏览 4提问于2016-06-15得票数 0
回答已采纳
我有一个后端应用程序，它使用AMQ/Camel来消耗消息。在每次消息处理期间，使用@Transactional JDBC完成数据库插入。我配置了两个消息代理。最后，代理将执行消息回滚，然后应用程序再次获得相同的消息，从而导致数据库错误，因为它们已经被插入。
如何配置路由，使其在连接中断时尝试回滚？如果我以编程方式管理事务，这是可能的吗？
浏览 3提问于2016-03-10得票数 1
回答已采纳
我正在使用应用程序服务器迁移实用程序来帮助我进行迁移。所列问题之一是：
我检查了帮助中提到的细节，但从细节上看不太清楚。
浏览 4提问于2020-03-06得票数 0
2回答
只有在两个事务都成功的情况下，我才希望返回成功。如果密码更改成功，解锁失败，则不能发送成功或失败。因此，我希望在更改密码之前创建一个回滚点，如果两个查询都成功执行，我将提交事务。如果其中一个查询失败，我将通过回滚回滚点来丢弃更改。我正在使用ADO在C++中这样做。是否有任何SQL查询，使用我可以创建回滚点并恢复到回滚点并执行事务
浏览 4提问于2010-04-15得票数 1
2回答
A.b.如果对#a的回答是肯定的，那么“必需”策略的关联事务管理器应该是什么？是JmsTransactionManager还是JpaTransactionManager？A.c.由于DEST_QUEUE位于生产者端，所以(A.5)中的JMS需要处理吗？B. from("jms:queue:SRC_QUEUE") //(B.1) transactional jms endpoint .transacted((B.1)中的JMS</e
浏览 6提问于2020-02-16得票数 3
回答已采纳
2回答
如何停止无限回购？我想丢弃一条消息，以防出现错误。Camel configuration <camel:exception>java.lang.Exception</camel:exception" /> &l
浏览 2提问于2011-09-22得票数 1
回答已采纳
1回答
我试图使用activemq和camel部署应用程序，当我在运行tomcat服务器时，我在控制台上接收所有可疑消息，即使tye broker上队列中没有消息，错误消息是09:56:27.770 [CamelJmsConsumer[events]] DEBUG org.apache.activemq.ActiveMQSe
浏览 0提问于2013-02-08得票数 2
1回答
我一直在读关于JMS、ActiveMQ和Camel的文章。
据我所知，如果我们需要集成多个系统，其中集成只涉及相同格式的消息路由，activeMQ就足够了，否则我们可以选择camel。现在，如果某些异常或事务回滚导致消息重新传递过期，activeMQ会将失败的消息发送到死信队列。我们没有使用Apache camel，因为activeMQ足以满足我们的需求，但是如果我想监控和审计失败的消息，我是否应该选择camel，或者它会增加开销吗？
浏览 19提问于2018-08-20得票数 0
回答已采纳
我正在设置一个项目，在这个项目中，JMS的批量提交必须在一次尝试中完成。使用事务重新启动消息处理，因此需要思考如何将"x“消息数量推到JMS队列并执行JMS提交。目前正在做的是创建一个JMS消息，其中一个长字符串附加了我希望一次提交的消息。然后使用拆分器在另一条路由中将消息拆分为多个。最后，使用另一条路由将消息发送到JMS (作为批量提交</em
浏览 0提问于2019-05-27得票数 0
回答已采纳
1回答
我正在设计JMS应用程序，它接收来自队列的消息并更新数据库中的列。我使用tomcat和消息侦听器来侦听消息(没有MDB，也没有Spring )。我希望在异常处理和事务处理中，最好的、健壮的设计，这样消息就不会丢失。谢谢
浏览 6提问于2013-07-11得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
