在Apache Camel路由中使用动态日志名

否不使用 <log> 在骆驼路线上。这是静态的。您可以使用 <bean> 或 <processor> 在Java代码中,您可以编写一些动态记录的Java代码。

这是我的处理器,我用于动态记录器。请随意使用它。此进程使用 Expression 将简单语言转换为字符串和 CamelLogger 记录消息。logName的后缀由 logger 收割台;

public class CustomLogger implements Processor {
    private static final String LOGGER_PREFIX = "com.acme";

    final String simple;
    final LoggingLevel level;

    public CustomLogger(String simple, LoggingLevel level) {
        this.simple = simple;
        this.level = level;
    }

    @Override
    public void process(Exchange exchange) throws Exception {
        Expression expression = exchange.getContext().resolveLanguage("simple").createExpression(simple);
        new CamelLogger(
                String.format("%s.%s", LOGGER_PREFIX, exchange.getIn().getHeader("logger", "default")),
                level
        ).log(expression.evaluate(exchange, String.class));
    }
}

用法

from("direct:someRoute")
    .process(new CustomLogger("This should go to ${in.headers.logger} logger", LoggingLevel.INFO))
    .to("log:done");