Apache camel从body（）获取值

Question

public class MyCamelRoute {

    public static void main(String... args) {
        CamelContext context = new DefaultCamelContext();
        try {
            context.addRoutes(new CSVRoute());
            context.start();
            Thread.sleep(20000);
            context.stop();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

class CSVRoute extends RouteBuilder {

    public void configure() throws Exception {
        CsvDataFormat csv = new CsvDataFormat();
        from("file:my_csv.csv&noop=true")
        .split(body().tokenize("\n")).streaming()
        .unmarshal(csv)
        .log(LoggingLevel.INFO, body().toString());
    }
}

13:30:42.739[Camel(camel-1)线程#1-文件://my_csv.csv]信息路由1-简单{[[567892]]}

13:30:42.741[Camel(camel-1)线程#1-文件://my_csv.csv]信息路由1-简单{[[269041]]}

13:30:42.743[Camel(camel-1)线程#1-文件://my_csv.csv]信息路由1-简单{[[622768]]}

我以前所做的只是将它发送到一个进程，然后使用exchange.getbody().getin()并从那里检查/强制转换它，但我想尽量避免使用进程。

非常感谢所有的帮助

Answer 1

要记录邮件正文，必须使用

.log(LoggingLevel.INFO, "${body}");

因为信息是默认的，所以做起来更快

.log("${body}");

你还可以写一篇文章

.log("The message contains: ${body}");