Hi Felix, I have a unit test which confirms your finding. Could you please open an JIRA and post the ticket number here. I will have a closer look during the next days. As workaround, you could also set the limit in the SQL query. Something like: select * from TBL_DATA_AC LIMIT 2
Best, Christian ----------------- Software Integration Specialist Apache Member V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer Apache Incubator PMC Member https://www.linkedin.com/pub/christian-mueller/11/551/642 On Wed, Jan 6, 2016 at 4:04 PM, Felix Thomas <felix.tho...@gmail.com> wrote: > hello, > > I have an issue (not sure if its a bug) in camel. I have tested in > multiple versio*n i.e. 2.15.1,2.16.0,2.16.1 *also but still the same > result. > > I have a route defined below in spring XML . When i start the camel > instance it works fine at the first time i.e it fetches only 2 records as > expected . But when the timer kicks in after 1 minute again it fetchs all > the rows in the table . I expect it to fetch only 2 again. Is there an > issue in my route definition ?? > > > <route customId="true" id="ROUTE_TBL_DATA_AC" xmlns=" > http://camel.apache.org/schema/spring";> > <from uri="timer://getDataROUTE_TBL_DATA_AC?period=1m"/> > <setBody id="setBody2"> > <constant>select * from TBL_DATA_AC</constant> > </setBody> > > <to > uri="jdbc:DSROUTE_TBL_DATA_AC?*statement.maxRows=2&*amp;outputType=StreamList" > id="to8"/> > <split parallelProcessing="true" streaming="true" id="split1"> > <simple>${body}</simple> > <convertBodyTo type="java.lang.String" /> > <multicast parallelProcessing="true" > executorServiceRef="customThreadPoolProfile" id="multicast1"> > <pipeline id="pipeline1"> > <to > > uri="rabbitmq://localhost/QUEUE?autoDelete=false&autoAck=false&queue=DEV&username=guest&password=guest&routingKey=DEV&durable=true" > id="to9"/> > </pipeline> > </multicast> > </split> > </route> > > > > regards, > Felix >
