Hi, > The efficiency problem is that all of this is done by a single Java thread. > Thus if I have many sources, there is a huge bottleneck.
By default each consumer should generate incoming messages in the separated thread. If you consume from two data source in two separated routes, each of them should be processed by separated thread as well. Can you show us your routes definitions? Cheers. -- Henryk Konsek http://henryk-konsek.blogspot.com