Я пытаюсь использовать шаблон RecipientList в Camel, но я думаю, что могу упустить суть. Следующий код отображает только одну запись на экране:
@Override
protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
from("direct:start").recipientList(bean(MyBean.class, "buildEndpoint"))
.streaming()
.process(new Processor() {
@Override
public void process(Exchange exchange) throws Exception {
System.out.println(exchange.getExchangeId());
}
});
}
};
}
public static class MyBean {
public static String[] buildEndpoint() {
return new String[] { "exec:ls?args=-la", "exec:find?args=."};
}
}
Я также попытался просто вернуть строку с разделителями-запятыми из метода buildEndpoint () и использовать tokenize (",") в выражении определения компонента recipientList (), но я все равно получил тот же результат. Что мне не хватает?
