骆驼交换身体记录大小

Question

脚本：

• CSV文件被发送到我的endpoint，Pojo将java数据和消息转换为我的一条路由，比如（“direct:consume”）路由，然后处理器处理该文件，处理消息并创建新的输出

问题：

• 文件只包含代码中断的一行
• 文件包含多行代码工作

尝试：

• 试图找到一种方法来确定交易记录的数量。getIn（）。getBody（）
• 阅读stackoverflow
• 阅读有关exchange的文档
• 在不知道记录数量的情况下，检查java代码中对象/对象到列表的转换

代码：

    public void process(Exchange exchange) throws Exception {
    List<Cars> output = new ArrayList<Cars>();
    **List<Wehicle> rows = (List<Wehicle>) exchange.getIn().getBody(); <-- Fails**

    for (Wehicle row: rows) {
        output.add(new Cars(row));
    }

    exchange.getIn().setBody(output);
    exchange.getIn().setHeader("CamelOverruleFileName", "CarEntries.csv");
}

韦希尔

...
@CsvRecord(separator = ",", skipFirstLine = true, crlf = "UNIX")
public class Wehicle {
    @DataField(pos = 1)
    public String CouponCode;

    @DataField(pos = 2)
    public String Price;
}
...

汽车

@CsvRecord(separator = ",", crlf = "UNIX", generateHeaderColumns = true)
public class Cars {
    @DataField(pos = 1, columnName = "CouponCode")
    private String CouponCode;

    @DataField(pos = 2, columnName = "Price")
    private String Price;
    
    public Cars(Wehicle origin) {
        this.CouponCode = Utilities.addQuotesToString(origin.CouponCode);
        this.Price = origin.Price;
    }
}

输入：

"CouponCode","Price"
"ASD/785", 1900000
"BWM/758", 2000000

问题：

• 如何创建动态调用列表，无论我得到的是一个对象还是多个对象？——交换getIn（）。getBody（）返回对象

很长一段时间没有使用java了，加上对camel来说是个新手。

Answer 1

在重新检查官方文件后，以下更改似乎解决了这个问题。

代码：

    public void process(Exchange exchange) throws Exception {
    List<Cars> output = new ArrayList<Cars>();
    List records = exchange.getIn().getBody(List.class);
    (List<Wehicle>) rows = (List<Wehicle>) records;

    for (Wehicle row: rows) {
        output.add(new Cars(row));
    }

    exchange.getIn().setBody(output);
    exchange.getIn().setHeader("CamelOverruleFileName", "CarEntries.csv");
   }