当在IBM MQ连接上进行提交时，当连接未被事务处理时？我在Camel2.10.4路由中配置JMS事务，我的应用程序是消费者和生产者。我需要从一个队列中读取数据，然后写入其他队列。我的应用程序上下文XML配置文件中的相关部分如下所示： class="org.apache.camel.component.jms.JmsConfiguration
浏览 2提问于2015-07-01得票数 0
1回答
如果camel DSL被标记为transacted()，那么我们真的需要在Spring服务方法中添加@Transactional注释吗？
我真的很想知道骆驼和Spring之间的事务交互。
浏览 0提问于2019-03-20得票数 1
回答已采纳
使用java JMS API，我从DB获得一个字节数组，然后将其作为javax.jms.BytesMessage发送到ActiveMQ。在使用camel之后，我想将文件放在一个位置上， <route>
<from uri="activemq:queue.fileOuput"/>-57401-1347652410053-0-1-1-1-1，但我想将我的名称放在数据库中，如MyFile.xml。我尝
浏览 0提问于2012-09-15得票数 0
回答已采纳
我的应用程序的工作流程：，我已经设置了activemq，并编写了spring框架来侦听activemq的队列。每当队列中有消息时，侦听器将得到消息，然后将消息排出队列，并执行业务逻辑。activecamel.xml包含以下代码
<camelContext id="activeContext" xmlns="http://camel.apache.org/schema/spring">routeBuilder ref="activeMQRouter"
浏览 2提问于2013-09-18得票数 3
1回答
如何在JMS路由中设置事务，以便在发生异常时回滚或不使用消息。下面是我的路线。MQ是ActiveMQ。from("jms:queue:myQueue") .doTry()
.toF("reactive-streams
浏览 12提问于2020-07-06得票数 0
1回答
在我们的解决方案中，我正在考虑使用Apache camel来实现EIP模式。我们的需求是构建一个能够从故障中恢复的容错系统。我了解Apache Camel (死信通道)提供的本机错误处理功能，它们满足了我的需求。我认为Spring Integration提供了创建持久通道的配置。Apache Camel是否支持类似的
浏览 3提问于2017-10-19得票数 0
我正在尝试从Camel 2.0升级到2.6通过在中间加上两行(策略和事务)，我得到了异常.原因: org.apache.camel.FailedToCreateRouteException:未能在路由中创建路由route2 at：>>> FromtransactionSaleBuffer <您需要向路由添加输出，如to("log:foo")。我的<em
浏览 0提问于2011-04-12得票数 0
回答已采纳
我正在尝试创建一个路由器来集成许多JMS主题&队列。我受到以下事实的限制:我工作的客户端无法更改JMS (带有一些自定义客户端库)，以及它们编写了自己的XA事务管理器，这与JTA不太一致。我对Camel做了大量的阅读和实验，我意识到我可能需要编写自己的JMS组件，因为标准JMS组件不会与JMS客户机库或TM集成。我需要能够在以下几点将钩子放入路由生命周期：
在路由启动期间，我需要识别所有JMS连接，并将它们作为XA资源登记到TM实现中。当消
浏览 0提问于2016-02-22得票数 2
回答已采纳
3回答
我有一个用于从JMS队列中读取项目并将其写入数据库的路由。我已经阅读了有关Apache Camel JMS组件的文档，但我没有得到我的问题的确切而明确的答案，即“如果路由中发生某些异常，JMS使用者是否会在JMS队列中重新插入项或解锁消息？”阿里
浏览 0提问于2013-05-28得票数 2
回答已采纳
现在，我有了一个程序来侦听一个jms队列，它在程序毫无例外地消耗消息之后，使用客户端确认模式提交事务。javax.jms.Message msg = message.getJmsMessage(); } catch (Exception e) { }<camelContext id="<e
浏览 1提问于2019-04-15得票数 1
回答已采纳
我们正在研究在新系统中使用Camel；我们的情况之一是启动了一组步骤，其中一些步骤可能需要几个小时或几天的时间才能执行。在这些耗时很长的步骤完成后，我们需要执行其他步骤。我知道我们可以使用队列消息传递系统，例如JMS，并且放入这样一个队列中的消息可以被处理为持久化。我不清楚的是，这如何(或是否)适合Camel --我们是否需要将每个队列后面的步骤视为自己的路由，以便它可以在启动时从队列中读取数据？是否有Camel构造/构造可以辅助这种系统？如果我知道它们的术语和基本轮廓，我可能就能弄明白，但我真正需要的是对这些构
浏览 2提问于2017-09-22得票数 0
2回答
XA事务真的是原子的吗？
、、、
似乎我并不完全理解XA事务是如何工作的。我认为它是原子的:我认为当我提交一个事务时，新消息和新数据将同时可用。第二个路由被配置，以便在发生异常时将消息回滚到队列。我看到了，在第二次跑步之后，路线看到了行！最后，我要提出以下几个问题：
如果不是，如何为事务</
浏览 2提问于2013-02-04得票数 2
我正在设置一个项目，在这个项目中，JMS的批量提交必须在一次尝试中完成。使用事务重新启动消息处理，因此需要思考如何将"x“消息数量推到JMS队列并执行JMS提交。目前正在做的是创建一个JMS消息，其中一个长字符串附加了我希望一次提交的消息。然后使用拆分器在另一条路由中将消息拆分为多个。最后，使用另一条路由将消息发送到JMS (作为批量提交)。token="\n"/>
<to u
浏览 0提问于2019-05-27得票数 0
回答已采纳
如何在camel DSL中处理()与transacted=的JMSComponent“真”有关。如果在camel DSL中，JMSComponent的事务属性被设置为"true“以及transacted()，这有什么意义吗？
浏览 0提问于2019-01-07得票数 2
回答已采纳
当我使用AMQP组件而不启用事务时，它工作得非常好。在Camel端点上设置transacted=true配置选项
DEBUG org.apache.camel.util.IntrospectionSupport: Configured property: transactionManager: org
浏览 1提问于2015-06-25得票数 2
回答已采纳
但是当我使用camel延迟选项时，它不是在队列中延迟，而是立即被消耗，并在路由路径中延迟。我们如何延迟消息，使它们在队列中停留几秒钟？ <property name="connectionFactory" ref="jmsConnectionFactory&quo
浏览 3提问于2015-11-05得票数 0
1回答
我已经参考过Camel文档的JMS页面以及许多相关的问题，但我无法找到关于实现的全面列表。<camel:route id="test"> <camel:to uri="fi
浏览 1提问于2016-07-28得票数 1
回答已采纳
我正在尝试设置一个camel上下文，该上下文轮询weblogic jms队列，使用消息并将其发送到webservice端点。如果事务中出现任何错误或目标系统不可用，我需要重新传递相同的消息，而不会丢失顺序/排序。我已经设置了一个单消费者的camel jms路由，并根据https://camel.apache.org/transactional-client.html启用了事务属性，并将重新交付<
浏览 26提问于2019-06-14得票数 0
回答已采纳
我已经启用了JMS事务，如本文档所述：这个队列上没有消息，但我在Camel日志中可以看到，它启动和结束了多个JMS事务，并且在不同的线程id中多次发生这种情况。它们真的在循环中提取JMS消息吗？我能把它换成推杆吗？
浏览 2提问于2015-06-01得票数 1
回答已采纳
我正在使用ActiveMQ和Atomikos - transacted设置Camel。当在处理器中抛出RuntimeException时，我期望ActiveMQ重试消息，但是消息不会返回到队列？First Camel在RuntimeException被抛出之前重试了3次-事务被回滚，但队列上没有任何东西，也没有重试？(DelegateAsyncProcessor.java:86)
at org.apache.camel.component.jms.EndpointMessageL
浏览 3提问于2013-06-05得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
实时音视频活动推荐
腾讯云开发者
