java - Apache Camel 路由配置中返回 Future 的 Bean 方法

Question

嗨，我开始使用 Apache Camel，我想知道是否可以像这样使用 Camel:

一些服务(bean):

public class SomeService {
    public Future<Data> someMethod() {
        //Do async job
    }
}

RouteBuilder伪配置:

public class MyRouteBuilder extends RouteBuilder {
    SomeService someService; //injected instance

    public void configure() {
        from("source.route")
            .bean(someService, "someMethod")
            .to("destination.route.after.job.started")
            .afterTo("destination.route.after.job.finished") //afterTo is a concept
        .end()
    }
}

因此，destination.route.after.job.started将在someMethod返回后立即到达。并且 destination.route.after.job.finished 将在异步作业完成后到达。

Answer 1

您可以使用AsyncProcessor如 cookbook 中所述。用法如下:

from("file:data/in").process(new MyValidator()).threads(20)
.process(new MyTransformation()).to("jpa:PurchaseOrder");

有关更多详细信息，请阅读食谱，然后询问更详细的问题(如果您有的话)。