Apache骆驼侦听器

Question

我创建了一个路由器类，并在@Configuration中标记为@Bean。有一件事我不太确定，那就是camel会多久调用一次数据库以获取select结果？一旦我在数据库中有了一个新条目，camel就会检索并处理它。

public class SQLRouteBuilderForNewUserProcessing extends RouteBuilder {

    @Override
    public void configure() throws Exception {
        //files refer camel files endpoint
        //noop will not move or delete the files
        from("sql:" +
             "select id from users where status=" + Status.NEW.ordinal() +
             "?" +
             "consumer.onConsume=update users set status = " + Status.PROCESSING.ordinal()
             " where id = :#id")
            .bean(UserDataTranslator.class, "transformToUserData")
            .to("log:uk.co.infogen.users?level=INFO");
    }
}

Answer 1

consumer.delay长500骆驼2.11：仅SQL消费者：每次投票之间的毫秒延迟。

从http://camel.apache.org/sql-component.html

Answer 2

默认情况下，sqlconsumer每隔500毫秒对数据库进行一次池处理。您可以使用消费者配置。延迟

from("sql:select ... &consumer.delay=5000")
  .to(...)

请参见sql组件的留档