我刚接触apache camel，无法理解重新交付和回滚之间的区别。你能帮我理解一下吗？
浏览 19提问于2018-12-19得票数 0
回答已采纳
我需要从队列中读取一条消息，然后调用REST服务进行发布。然后，我查看了，看起来您可以设置一个maximumRedeliveries来再次处理队列消息，所以在失败的情况下回滚事务，我想知道在同一条骆驼路由中，如果我们必须调用REST服务来发布某件东西，该部分如何回滚useOriginalMessage() .logHandled(false) );
路由的
浏览 0提问于2018-11-20得票数 0
回答已采纳
2回答
<property name="redeliveryDelay" value="10000" /> </property>我在应用程序中的各种不同端点之间还有其他几个路由，这些路由需要重新交付配置，并且行为与预期一致。但是，这种特定的路由类型(从文件到队列)似乎不遵循我配置的任何重新传递
浏览 77提问于2013-11-28得票数 1
回答已采纳
1回答
我试图使用activemq和camel部署应用程序，当我在运行tomcat服务器时，我在控制台上接收所有可疑消息，即使tye broker上队列中没有消息，错误消息是
09:56:27.769 [Camel(eventProcessorCamelContext) thread #2 - JmsConsumer[events]] DEBUG org.apache.activemq.ActiveMQSession(eventProcessorCamelContext) thread #1 -
浏览 0提问于2013-02-08得票数 2
我想开发一个小型的集成微服务，它实现了两个现有系统之间的通信。 系统A有一个Apache Kafka主题，用于生产和消费消息。 系统B具有REST API，并且能够调用REST API回调。我正在尝试开发的解决方案必须能够与每个系统进行通信，转换消息并将其传递到另一个系统(同时进行广泛的日志记录等)。消息的数量和大小为小..。性能不会成为问题。我选择的堆栈是Spring Boot +用于路由
浏览 56提问于2021-02-28得票数 0
回答已采纳
1回答
我一直在读关于JMS、ActiveMQ和Camel的文章。
据我所知，如果我们需要集成多个系统，其中集成只涉及相同格式的消息路由，activeMQ就足够了，否则我们可以选择camel。现在，如果某些异常或事务回滚导致消息重新传递过期，activeMQ会将失败的消息发送到死信队列。我们没有使用Apache camel，因为activeMQ足以满足我们的需求，但是如果我想监控和
浏览 19提问于2018-08-20得票数 0
回答已采纳
1回答
如果在消息处理期间发生未处理异常，则回滚事务并重试。问题是，它立即让重试，每秒几次，可能会对IBM管理器和外部系统造成很大的负载。
交易模式下的重新交付不是由Camel处理，而是由支持系统(事务管理器)处理。在这种情况下，您应该求助于支持系统如何配置重发。有一些关于Tran
浏览 1提问于2020-10-17得票数 1
我已经将apache camel重新传送策略配置为camel路由之一。我需要编写junit来验证路由在成功和失败情况下是否正常工作。我能够为失败场景编写junit，并且能够通过模拟路由中的服务返回异常来验证最大重发是否按照配置发生。在积极的场景中，我希望mock路由中的服务在前3次尝试时返回异常，在最后一次重新交付尝试(4)时，我希望mock服务返回期望值，而不返回任何异常。(3次尝试失败，但第4次
浏览 4提问于2021-04-01得票数 0
1回答
我是Apache camel - groovy，maven项目的新手。我正试图创造一条这样的路线 .transacted("PROPAGATION_REQUIRED")但是，由于整个路由包含一个回滚调用，所以我希望回滚最后发送的cxf请求。有人能帮我
浏览 2提问于2015-03-30得票数 0
回答已采纳
2回答
我有一个错误处理的问题。如果jrnRoute中发生异常，则由exceptionHandler处理器处理该异常。这样就可以了。但是导致异常的消息仍然停留在jrnQueue中，被再次处理并一次又一次地导致错误。此外，我在日志中有一个警告(见下文)。如何停止无限回购？我想丢弃一条消息，以防出现错误。Execution of JMS message listener failed, and no ErrorHandler has been set.
org.apache.camel.RuntimeCamelExc
浏览 2提问于2011-09-22得票数 1
回答已采纳
我正在尝试使用JPATransactionManager运行clause ()路由(一个独立的java进程)是spring PlatformTransactionManager (因为我希望camel路由在单个我只希望MQ在出现服务崩溃时重新交付。和doCatch事务块中的异常
骆驼再运送，然后再处理(真)。按照重发策略(有效)尝试重发，但是MQ不应该重新交付。我希望我的骆驼路径在一个db事务<
浏览 4提问于2019-04-10得票数 1
1回答
带HornetQ的JBoss 5.1@TransactionTimeout(30000)注释似乎不起作用。TransactionManagementType.CONTAINER) @TransactionAttribute(value = TransactionAttributeType.REQUIRED)
当前行为是，如果5分钟过去，JMS将回滚事务。但是，通过这种方式，代码会多次执行:对于第一次交付和
浏览 1提问于2011-02-17得票数 2
我一直在尝试在我的camel上下文(camel 2.8)中配置一个jms端点(activemq5.7)，因此它应该在回滚时使用消息的重新传递。不幸的是，它并没有像我预期的那样工作:它将一条消息返回到一个队列，但是消费者在那之后立即接收消息，尽管有指定的延迟参数。...<bean id="jmstx" class=&quo
浏览 0提问于2012-12-21得票数 2
如果JMSXDeliveryCount (一个消息属性)小于5，我希望回滚。如果大于5，我想记录一条消息并离开。下面是我的routeContext： </when>
<other
浏览 2提问于2018-04-06得票数 2
我正在使用Apache camel 3.1.0和Spring boot 1.5.6，我已经成功地创建了完美工作的Camel事务路由。基本路由是这样的 from(Source JmsEndpoint)myDaoImplClass.myTransactionalDatabaseMethod("Save data comingin Message")
).to(Destination Endpoint) 当目标队列上的队列深度变满，并
浏览 12提问于2020-11-25得票数 0
我使用这个子句来捕获在我的项目中发生的所有异常，以定制它的行为。抛出异常的路径是： <from uri="[[toFilepath.forUpload.read]]"/>fileName.toFtp]]</simple></setHeader>
<to id="uploadFil
浏览 0提问于2014-01-08得票数 1
我编写了这个用于教育apache camel事务的代码。-> { })在发生错误后，我使用事务处理，我必须触发事务回滚，但由于某种原因，消息仍然保留在SAMPLE_2和SAMPLE_3队列中。为什么？" ref="jmsConfig" />
</
浏览 1提问于2019-08-27得票数 0
首先:我是骆驼新手:-)onException(Exception.class).handled(true).to("file://C:/temp/camel/error");
from("file://C:/t
浏览 6提问于2012-06-07得票数 2
2回答
我有一个在Karaf内运行的Camel路由，为此我添加了一个死信频道。这是为了处理路由失败的情况，我想保留问题消息并记录原因。我不能将异常抛回调用应用程序，因为我正在异步处理一些处理。通过阅读文档和尝试大量案例，我不清楚如何将异常记录到Karaf的日志中，并将原始消息放到死信队列中。以下是我所获得的摘录：
<bean id="deadLetterQueue" class="org.
浏览 0提问于2012-12-05得票数 9
回答已采纳
我已经设置了Apache camel，在其中，我使用来自一个队列的消息，并对其执行某种操作，然后将其传输到其他队列。现在，如果异常出现了，那么我希望它应该回滚，然后在6次尝试将其发送到死信队列后，当前回滚会发生5-6次，但我的消息不会被传输到死信队列。这里发生的事情->Queue1 1->(消耗) -->操作(抛出的异常)->回滚->再一次Queue1 1->(消
浏览 0提问于2018-08-28得票数 1
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
