Apache Camel中失败后重新入队/重试消息的惯用实现方式？

你的实现思路能满足需求，但并非Apache Camel中的惯用做法，存在一些可优化的点：

• 每次重试都会触发wireTap，导致同一条消息被重复持久化
• 手动将消息发回原队列的方式，易引发循环依赖，若队列配置不当可能导致消息积压或重复处理
• 未利用Camel内置的错误处理与重试机制，代码冗余且可控性弱

推荐的惯用实现方式 #

方案一：结合事务与内置重试机制（推荐）

如果你的消息队列和持久化端点支持事务（如JMS队列、数据库持久化），可通过事务保证消息处理的原子性，同时用onException配置重试逻辑：

from(incomingQueue)
    .routeId("incomingQueue")
    .transacted() // 开启事务，确保消息取出、持久化、SOAP投递要么全成功要么全回滚
    .log("sending to partner")
    .to(persistOutgoingUri) // 同步持久化，确保消息先落地再执行SOAP投递
    .onException(IOException.class)
        .log("SOAP delivery failed, retrying in 10 seconds...")
        .delay(10000)
        .retryWhile(exchange -> true) // 无限重试直至投递成功
        .end()
    .to(sendViaSoap)
    .log("Got Response for SOAP: ${body}");

方案二：无事务场景下的重试优化

如果不需要事务支持，也可以用doTry-doCatch配合rollback()实现重试，避免手动回队的繁琐：

from(incomingQueue)
    .routeId("incomingQueue")
    .log("sending to partner")
    .to(persistOutgoingUri) // 同步持久化，仅执行一次
    .doTry()
        .to(sendViaSoap)
        .log("Got Response for SOAP: ${body}")
    .doCatch(IOException.class)
        .log("SOAP delivery failed, retrying in 10 seconds...")
        .delay(10000)
        .rollback() // 回滚至doTry起始点，重新执行SOAP调用
        .end();

优化点说明 #

1. 避免重复持久化：将异步的wireTap改为同步的to，确保消息仅被持久化一次，重试仅针对SOAP投递步骤
2. 内置重试机制：利用Camel原生的onException或rollback()实现重试，无需手动管理消息回队，逻辑更简洁可控
3. 事务一致性：通过transacted()保证消息处理的原子性，避免消息丢失或半处理状态

内容的提问来源于stack exchange，提问作者hans lux