0

我是使用 Apache Camel 的新手。你能帮我移动文件吗？我有这样的路线：

from("file:data?noop=true?move={{package.success}}&moveFailed={{package.failed}}")
                .split(ExpressionBuilder.beanExpression(new InvoiceIteratorFactory(), "createIterator"))
                .streaming()
                .process(new ValidatorProcessor())
                .choice()
                .when(new Predicate() {
                    @Override
                    public boolean matches(Exchange exchange) {
                        ..;
                    }
                })
                .to("jpa://...?consumer.transacted=true")
                .otherwise()
                .aggregate(header(PropertyNameConstants.AGGREGATOR_HEADER), new ErrorsAggregationStrategy())
                .completionPredicate(new Predicate() {
                    @Override
                    public boolean matches(Exchange exchange) {
                     ...;
                    }
                })
                .to("smtps://smtp.gmail.com?username={{remote.e-mail}}&password={{remote.password}}");

因此，应将有错误的文件移至“失败”目录，将没有错误的文件移至“成功”目录。我尝试在聚合所需消息后生成异常（在解析有错误的文件时），以便将文件移动到目录“失败”，但所有文件都移动到目录“成功”，即使出现异常。

如果我在聚合器之前抛出异常，文件移动到“失败”目录但最后一个“到”（发送邮件）不起作用。

4

1 回答 1

0

如果你有 Camel in Action 的副本，那么我建议阅读第 8 章关于聚合器 EIP 以了解它是如何工作的，以及它是一个有状态 EIP 的事实，因此存在 Exchange 的切换，因此消费者完成。来自聚合器的聚合交换独立于原始消费交换执行。

此外，您可能想查看组合消息处理器 eip，并使用仅拆分器版本

于 2014-05-14T19:19:05.713 回答