如何从log4j的日志文件中获取Apache Camel消息历史记录？

burner 发表于 Dev

燃烧器

在Apache Camel documantation中是一个很好的消息历史记录。我想要这个作为我的errorHandler。所以我做

errorHandler(
            deadLetterChannel("direct:deadLetter")
                .logExhaustedMessageHistory(true)
                .maximumRedeliveries(3)
                .retryAttemptedLogLevel(LoggingLevel.WARN)
                );

并且：

CamelContext context = getContext();
context.setMessageHistory(true);

但是，不会在控制台中和日志文件中显示漂亮的消息历史记录。我该如何激活呢？

我的log4j附加程序是：

<Appenders>
    <Console name="STDOUT" target="SYSTEM_OUT">
        <PatternLayout pattern="%d{yyyy/MM/dd-HH:mm:ss} %-5p %C:%M:%L ~ %m%n"/>
    </Console>
...

我已经搜索过Google，但是我只找到上面的信息，而这些信息不起作用。

谢谢

编辑：

这项工作，但我失去了deadLetterChannel。这是一个错误吗？

errorHandler(
        defaultErrorHandler()
        .logExhausted(true)
        .logExhaustedMessageHistory(true)
        );

燃烧器

我解决了问题：

errorHandler(
        deadLetterChannel("direct:deadLetter")
            .maximumRedeliveries(3)
            .retryAttemptedLogLevel(LoggingLevel.WARN)
            );


from("direct:deadLetter").id("deadLetter")
    .routeId("deadLetter")
    .errorHandler(defaultErrorHandler().disableRedelivery())
    .process(new Processor() {
        public void process(Exchange msg) {
            String MsgHist = org.apache.camel.util.MessageHelper.dumpMessageHistoryStacktrace(msg, new DefaultExchangeFormatter(), false);
            LOG.error(MsgHist, msg);
            msg.getOut().setBody(msg.getIn().getBody(Document.class));
            msg.getOut().setHeaders(msg.getIn().getHeaders());
            msg.getOut().setHeader("MessageHistory",MsgHist);
        }
    })
    .log(LoggingLevel.ERROR,"${exception.stacktrace}")
    .setHeader("ErrorMessage",simple("${exception}",String.class))
    .setHeader("ErrorStacktrace",simple("${exception.stacktrace}",String.class))
            .to("activemqWithoutTransactions:errors");