骆驼体内的原始信息交换丢失

Question

我有一条骆驼路线，如下所示。

 from("jms:queue:start")
     .transacted()
     .bean(new FirstDummyBean(), "setBodyToHello")
     .bean(new SecondDummyBean(), "setBodyToWorld")
     .to("jms:queue:end")

bean方法顾名思义，分别将body设置为“Hello”和“World”。

我还设置了onException子句，如下所示：

onException(Exception.class)
    .useOriginalMessage()
    .handled(true)
    .to("jms:queue:deadletter")
    .markRollbackOnlyLast(); 

假设，我将一条消息放在队列“开始”上，正文为“测试消息”。在第一个杜米豆中成功处理后，我在第二个杜米豆中抛出一个运行时异常。我希望看到实际的消息或（原始消息内容完好无损，即“测试消息”）被发送到我的死信队列。

但是，死信队列上的消息内容是“Hello”。

为什么会这样？..

我使用的是apache camel 2.10.0。

还有谁能提供更多关于如何一起使用errorhandler和onexception子句的信息。文件上写着:

如果您已使用事务处理的DSL将路由标记为事务处理，则Camel将自动使用TransactionErrorHandler。它将尝试查找全局/每个路由配置的错误处理程序，如果它是 TransactionErrorHandlerBuilder 实例，则使用它
。如果没有，Camel将自动创建一个临时的TransactionErrorHandler，该处理程序会否决默认的错误处理程序。这是配置重于约定。

如何在JavaDSL中使用Transactionerror Handler的示例会很棒。

Answer 1

我在非事务示例中见过这种情况，似乎< code > useOriginalMessage()确实使用了原始交换，但是如果您修改了它引用的任何对象，您仍然会得到修改。< code>useOriginalMessage似乎没有返回队列以获取原始数据。

下面的代码包括一组演示问题的路线。定时路由将包含String“测试消息”的ArrayList发送到由第二个路由读取的队列。第二条路由将消息传递给修改列表内容的ModifyBody。接下来，消息转到TriggerException，并抛出RuntimeException。这是由onException路由处理的，尽管使用了useOriginalMessage，它还是会传递更新的主体。

import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;

import org.apache.camel.spring.SpringRouteBuilder;
import org.springframework.stereotype.Component;

@Component
public class TimedRoute extends SpringRouteBuilder {

    private static final String QUEUE = "jms:a.queue";
    private static final String QUEUE2 = "jms:another.queue";
    // The message that will be sent on the route
    private static final ArrayList<String> payLoad = new ArrayList<String>(
            Arrays.asList("test message"));

    public static class ModifyBody {
        public List<String> modify(final List<String> list) {
            final List<String> returnList = list;
            returnList.clear();
            returnList.add("Hello");
            return returnList;
        }
    }

    public static class TriggerException {
        public List<String> trigger(final List<String> list) {
            throw new RuntimeException("Deliberate");
        }
    }

    @Override
    public void configure() throws Exception {
        //@formatter:off
        onException(Exception.class)
             .useOriginalMessage()
             .log("Exception: ${body}")
             .handled(true)
             .setHeader("exception", constant("exception"))
             .to(QUEUE2);


        // Timed route to send the original message
        from("timer://foo?period=60000")
           .setBody().constant(payLoad)
           .to(QUEUE);

        // Initial processing route - this modifies the body.
        from(QUEUE)
            .log("queue ${body}")
            .bean(new ModifyBody())
            .log("after firstDummyBean: ${body}")
            .bean(new TriggerException())
            .stop();

        // Messages are send here by the exception handler.
        from(QUEUE2)
            .log("queue2: ${body}")
            .stop();
        //@formatter:on
    }
}

如果您将Modifybody替换为以下代码，则会在异常处理路由中看到原始消息。

public static class ModifyBody {
    public List<String> modify(final List<String> list) {
        final List<String> returnList = new ArrayList<String>(list);
        returnList.clear();
        returnList.add("Hello");
        return returnList;
    }
}

通过将正文更改为新列表，可以不修改原始交换。

做一个通用的解决方案是困难的，因为复制的机制将依赖于你正在运行的对象。您可能会发现，您可以扩展< code>RouteBuilder类，为自己提供一些复制对象的自定义DSL。