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.