RecipientList Apache Camel EIP

Question

我正在尝试在 Camel 中使用 RecipientList 模式，但我想我可能没有抓住重点。以下代码仅在屏幕上显示一个条目：

@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(",") 但我仍然得到相同的结果。我错过了什么？

Answer 1

这是预期的，收件人列表将同一邮件的副本发送给 X 个收件人。您之后执行的处理器在收件人列表完成后执行，因此只执行一次。