I tried this variation:

        routeDefinition =
            from(
                routeName
            )
            .threads()
            .executorServiceRef("bigPool")
            .inOnly(
                "vm:single.record.processor?concurrentConsumers=5&size=30"
            );


By adding concurrentConsumers=5&size=30, but got an error:

Cannot use existing queue vm://single.record.processor as the existing queue
size 2147483647 does not match given queue size 30





--
View this message in context: 
http://camel.465427.n5.nabble.com/Unable-to-setup-route-with-limit-of-30-queue-size-and-5-processing-threads-tp5766520p5766521.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Reply via email to