Apache Camel路由到顺序进程

Question

我有两条路线：

此刻我有：

public class FirstRouteBuilder extends RouteBuilder {

    @Override
    public void configure() {
        from(myqueue)
            .process(exchange -> {
                // prepare ResultObject
                // add to camel context the second route that is initializated with resultObject
                SecondRouteBuilder secondRouteBuilder = new SecondRouteBuilder(resultObject);
                camelCtx.addRoutes(secondRouteBuilder);
                camelCtx.start();
            });
    }
}

public class SecondRouteBuilder extends RouteBuilder {

    public SecondRouteBuilder (ResultObject result){
        this.resultObject = result;
    }

    @Override
    public void configure() {
        from(waitingAFileFromDirectory)
            .process(exchange -> {
                // process the file using the resultObject
            })
            .to(resultQueue);
    }
}

Answer 1

用pollency和loopDoWhile将它们连接起来

• pollenrice获取文件
• loopdowhile控制文件获取行为

public class CombineRouteBuilder extends RouteBuilder {

    @Override
    public void configure() {
        from(myqueue)
            .process(exchange -> {
                // prepare ResultObject and save to exchange property
            })
            .loopDoWhile(simple(<boolean gate to control file obtain strategy>))
                .pollEnrich(AFileFromDirectory)    // get your file
                // maybe a process to control boolean gate of loopDoWhile
            .end() // end loop
            .process(exchange -> {
                // process the file using the resultObject from exchange property
            })
            .to(resultQueue);
    }
}