将消息回滚到死信队列-Apache Camel

Question

我已经设置了Apache camel，在其中我使用来自一个队列的消息并对其进行某种操作，然后将其传输到其他队列。

现在，如果异常来了，我希望它应该回滚，然后在6次尝试后，它发送到死信队列，目前回滚发生5-6次，但我的消息没有转移到死信队列。

这里会发生什么-->Queue1->>（消耗）-->Operation（引发异常）-->Rollback-->Queue1->>（消耗）-->Operation（引发异常）-->Rollback-->...这种情况发生5-6次，然后我的消息丢失

我不知道消息的去向和丢失的原因，并且从活动的MQ GUI中我可以看到它已出列。

@Bean
public RedeliveryPolicy redeliveryPolicy() {
    RedeliveryPolicy redeliveryPolicy = new RedeliveryPolicy();
    redeliveryPolicy.setMaximumRedeliveries(2);
    redeliveryPolicy.setMaximumRedeliveryDelay(10000);
    redeliveryPolicy.setRedeliveryDelay(10000);
    return redeliveryPolicy;
}

---------------------Route extends SpringRouteBuilder-------------------

onException(MyException.class)
    .markRollbackOnly()
    .redeliveryPolicy(redeliveryPolicy)
    .useExponentialBackOff()
    .handled(true)

from("jms:queue:Queue1")
    .process(new Processor(){
       public void process(Exchange ex){
         throw new RuntimeException();
        }
    }).to("jms:queue:myQueue)

Answer 1

我假设有多重问题。

1. markrollbackonly停止消息。在此声明之后，不再进行进一步的路由。

这就是您的RedeliveryPolicy和OnException路由的其余部分被完全忽略的原因。您配置了2次重传尝试，但编写时会执行5次（ActiveMQ的默认重传）。

若要解决此问题，请将MarkRollBackOnly移动到OnException路由的末尾

由于在发生错误时丢失了它，因此事务配置有问题。配置Camel的ActiveMQ组件，使其在消费时使用本地JMS事务。

@Bean(name = "activemq")
@ConditionalOnClass(ActiveMQComponent.class)
public ActiveMQComponent activeMQComponent(ConnectionFactory connectionFactory) {
    ActiveMQComponent activeMQComponent = new ActiveMQComponent();
    activeMQComponent.setConnectionFactory(connectionFactory);
    activeMQComponent.setTransacted(true);
    activeMQComponent.setLazyCreateTransactionManager(false);
    return activeMQComponent;
}

这样做之后，您实际上可以删除onexception路由，因为重新传递是由JMS代理完成的，因此您必须在JMS连接上配置重新传递设置。如果配置的重新传递已耗尽，并且消息仍然产生回滚，则将其移动到DLQ。

使用其他onexception路由时要注意，因为这是纯骆驼路由。Camel错误处理程序不是在路由级别重新传递，而是在处理器级别重新传递。因此，如果同时配置broker和Camel redelivery，它可以将它们相乘。