I'm using camel I ended up using seda. Also stop converting to bean and using xstream as marshaller and did the marshalling by hand directly from SQL output.
Results are fast enough. See code below. http://i.imgur.com/jtBuMB8.png Thank you for all the help. @Component public class ReadDB extends SpringRouteBuilder{ @Override public void configure() throws Exception { from("quartz2://myGroup/myTimerName?trigger.repeatInterval=20000&trigger.repeatCount=0") .to("sql:select * from sales where integration_id = (select max(integration_id) as max_int from sales)") .split(simple("${body}")).streaming() .to("myLogger") .to("seda:sqlqueue?concurrentConsumers=8"); } } @Component public class WriteToQueue extends SpringRouteBuilder{ @Override public void configure() throws Exception { from("seda:sqlqueue?concurrentConsumers=8") .to("lineProcessor") .to("rabbitmq://xx.xxx.x.xx:5672/myExchange?username=xx&password=xx") ; } } -- View this message in context: http://camel.465427.n5.nabble.com/Camel-gradually-slowing-down-with-large-sql-results-tp5741560p5741643.html Sent from the Camel - Users mailing list archive at Nabble.com.
