如何在ApacheCamelDSL中回滚事务？

Question

我为教育阿帕奇骆驼交易编写了此代码

    from("jms:SAMPLE_1")
            .transacted()
            .log("message")
            .to("jms:SAMPLE_2")
            .to("jms:SAMPLE_3")
            .log("message")
            .process(exchange -> {
                throw new Exception();
            })
           .end();

我在发生错误后使用事务处理，我必须触发事务回滚，但由于某种原因，消息保留在SAMPLE_2和SAMPLE_3队列中。为什么？
更新：
我添加了豆子

@Bean(name = "PROPAGATION_REQUIRED")
public SpringTransactionPolicy propogationRequired(PlatformTransactionManager jtaTransactionManager){
    SpringTransactionPolicy propagationRequired = new SpringTransactionPolicy();
    propagationRequired.setTransactionManager(jtaTransactionManager);
propagationRequired.setPropagationBehaviorName("PROPAGATION_REQUIRED");
    return propagationRequired;
}
@Bean
PlatformTransactionManager platformTransactionManager(ConnectionFactory cf) {
    return new JmsTransactionManager(cf);
}

并修复路线，但这对我没有帮助：

from("jms:SAMPLE_1")
            .transacted("PROPAGATION_REQUIRED")
            .log("message")
            .to("jms:SAMPLE_2")
            .to("jms:SAMPLE_3")
            .log("message")
            .process(exchange -> {
                throw new Exception();
            })
           .end();

我在文档中找到了这个配置

<blueprint ...>
<bean id="jmstx" class="org.apache.camel.component.jms.JmsComponent">
    <property name="configuration" ref="jmsConfig" />
</bean>

<bean id="jmsConfig" class="org.apache.camel.component.jms.JmsConfiguration">
    <property name="connectionFactory" ref="jmsConnectionFactory" />
    <property name="transactionManager" ref="jmsTransactionManager" />
    <property name="transacted" value="true" />
</bean>
...

如何从这个xml创建bean？

Answer 1

是的，这不起作用，因为Camel JMS组件不知道您的事务管理器等。

正如您已经发现的，缺少组件配置。

我没有使用普通的JMS组件，而是使用ActiveMQ的专用版本，但它们非常相似。所以我希望你能从这个中得到缺失的bean。

@Bean(name = "activemq") // bean name is used in URI activemq:...
public ActiveMQComponent createComponent(ConnectionFactory factory) {
    ActiveMQComponent activeMQComponent = new ActiveMQComponent();
    activeMQComponent.setConnectionFactory(factory);
    activeMQComponent.setLazyCreateTransactionManager(false);
    activeMQComponent.setTransacted(true);
    return activeMQComponent;
}

重要的

如您所见，我没有在组件中设置事务管理器。只要你只和一个经纪人交谈，你就不需要tx管理器的东西(然后你从缓存设置中获利)。使用单一经纪人的交易

• 删除Spring事务管理器
• 删除Spring事务策略
• 从骆驼路由中删除 transacted（）

您只需要在Camel JMS组件上设置< code>setTransacted(true)和< code > setLazyCreateTransactionManager(false)，然后所有JMS使用者都会被处理。

您也可以在Camel文档中找到这两种设置。