java - Apache Camel 监听器

Question

我创建了一个路由器类并在@Configuration 中标记为@Bean。我不太确定的一件事是 Camel 多久会进行一次数据库调用以获得选择结果？一旦我在数据库中有了新条目，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

默认情况下，sql 使用者每 500 毫秒对数据库进行一次池化。您可以使用 consumer.delay

配置它

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

参见 the documentation of the sql component