I set the following route,
this.from("netty4:tcp://localhost:7000?sync=true&synchronous=false&encoder=#myEncoder&decoder=#myDecoder").to("disruptor:myDisruptor");
this.from("disruptor:myDisruptor?concurrentConsumers=20").to("bean:myHandler");
My transactions are processed sequentially even after having
concurrentConsumers=20 on disruptor. What might be the reason ? How can i
make message handler asynchronous ? The below route works for me,
this.from("netty4:tcp://localhost:7000?sync=true&synchronous=false&encoder=#myEncoder&decoder=#myDecoder").threads(20).to("bean:myHandler");
--
View this message in context:
http://camel.465427.n5.nabble.com/Disruptor-concurrentConsumers-tp5777771.html
Sent from the Camel - Users mailing list archive at Nabble.com.
