This is strange.

Upping the max memory to 3GB and changing from direct to seda with 4 paralel
consumers brought significant improvements (5x as fast), but it seems that
some messages got stuck and are sent only after a while:

First: http://i.imgur.com/oSmtZMP.png
And after a while:  http://i.imgur.com/hGh6HR2.png

That dip is really strange...

The VisualVM output: http://i.imgur.com/PsQlo1j.png

Any thoughts or help as to get this running more smoothly?









Code:
##############################################

@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=4");
    }

}


@Component
public class WriteToQueue extends SpringRouteBuilder{
        
    @Override
    public void configure() throws Exception {
        
        from("seda:sqlqueue?concurrentConsumers=4")
        //.threads(4)
        .to("lineProcessor")
        .marshal("xstream-utf8")      
       
.to("rabbitmq://xx.xx.x.x.:5672/myExchange?username=xxx&password=xxx")
        ;
    }

}





--
View this message in context: 
http://camel.465427.n5.nabble.com/Camel-gradually-slowing-down-with-large-sql-results-tp5741560p5741595.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Reply via email to