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(...)
Comments
Post a Comment