apache-camel - 如何使用 Akka 1.3 集成在 Camel 中进行聚合？

Question

Akka 集成非常好，但我似乎找不到任何关于如何使用 Producer Actor 进行聚合的示例。我的制作人非常简单：

    class BindingCandidateProducer(config: Configuration)
            extends Actor
            with Producer
            with Oneway
            with Logging
            with Instrumented {

        import BindingCandidateJsonProtocol._

        def endpointUri = "file:data/bindings?fileName=bindings.${date:now:yyyy-MM-dd'T'HHmm}.mjson"

        override protected def receiveBeforeProduce = {
            case bindingCandidate: BindingCandidate => bindingCandidate.toJson.compactPrint
        }
    }

注意：mjson是“multi json”的内部名称，这是一种文件格式，其中每一行都是完整的 JSON 消息。

我正在尝试将多个 BindingCandidate 对象聚合到一个文件中。我如何以及在哪里指定我的聚合器？是生活在这个人之前的一个单独的演员吗？Akka 1.3 Camel 文档中没有关于聚合器的信息。Akka 2 文档没有提及 Camel，尽管代码仍然存在。Akka 论坛有一个关于骆驼聚合的主题。

我仍在使用 Akka 1.3、Scala 2.9，但使用的是 Camel 2.12.2。