java - Apache Camel listener -


i have created router class , marked @bean in @configuration. 1 thing not sure how camel making database call select result? have new entry in database, camel retrieve , process it.

public class sqlroutebuilderfornewuserprocessing extends routebuilder {      @override     public void configure() throws exception {         //files refer camel files endpoint         //noop not move or delete files         from("sql:" +              "select id users status=" + status.new.ordinal() +              "?" +              "consumer.onconsume=update users set status = " + status.processing.ordinal()              " id = :#id")             .bean(userdatatranslator.class, "transformtouserdata")             .to("log:uk.co.infogen.users?level=info");     } } 

by default, sql consumer pool database every 500ms. can configure consumer.delay

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

see the documentation of sql component


Comments

Popular posts from this blog

routing - AngularJS State management ->load multiple states in one page -

python - GRASS parser() error -

Swift game error message -