java - 如何等待Apache Camel JDBC作业完成

我的代码中有一个循环，可生成apache骆驼流。但是，每个这些作业都需要从Oracle数据库进行轮询，这会导致每个用户的最大会话数错误。原因是这些作业是异步的，因此导致应用程序达到其与数据库的连接数限制。因此，我需要一种方法来等待流程完成，然后触发下一个流程。我想知道是否有办法做到这一点？我尝试在每个循环的末尾使用Thread.sleep，但是没有用。

for (int i=0; i<tasks.size(); i++) {
    DataStore sourceStore = dataStores.get(tasks.get(i));
    DataSource source = sourceStore.getDataSource();
    DefaultRegistry registry = new DefaultRegistry();
    registry.bind(tasks.get(i).getName(), source);
    CamelContext context = new DefaultCamelContext(registry);
    try {
        context.addRoutes(new RouteBuilder() {
            @Override
            public void configure() throws Exception {
                from ("direct:start")
                .to("jdbc:" + tasks.get(i).getSourceDataStoreName())
                .split(body())
                // some other job
                ;
                                                }
            });
        } catch (Exception e) {
        e.printStackTrace();
    }
    context.start();
    ProducerTemplate producerTemplate = context.createProducerTemplate();
    producerTemplate.sendBody("direct:start", sourceStore.getQuery(tasks.get(i)));
    //Thread.sleep(40000); // did not work
}

最佳答案

我认为您应该尝试onCompletion。
根据文档，仅当原始路由完成后才调用onCompletion()之后的路由。您可以在onCompletion()之后执行您的工作，例如，您可以将任务结果发送到某个地方。

这是我简单的onCompletion()示例：

context.addRoutes(new RouteBuilder()
{

        @Override
        public void configure() throws Exception
        {

            from("timer://mytimer?repeatCount=2&fixedRate=true&period=3000")
                    .process(exchange -> {
                        System.out.println("Thread will sleep 2s");
                        Thread.sleep(2000);
                    }).onCompletion().process(exchange -> System.out.println("After completion"));
        }
});