Setting queueSize option on SEDA

Question

I have a seda queue where i set queueSize option according to the camel documentation

The route i have looks like:

from("seda:someQueue?concurrentConsumers=10&queueSize=10")
.process(someProcessor);

I'm getting the following error due to the queueSize option:

org.apache.camel.FailedToCreateRouteException: Failed to create route....bla bla bla.. There are 1 parameters that couldn't be set on the endpoint. Check the uri if the parameters are spelt correctly and that they are properties of the endpoint. Unknown parameters=[{queueSize=10}]..... [stacktrace continues here]

Can anyone point out what's wrong? I'm using Java 8, Camel 2.9.13

Answer 1

Notice that the documentation says that the option queueSize is component only, which mean you need to configure it on the SedaComponent instead. In other words you cannot configure it on the endpoint as you do in your route above.

For up to date documentation and better docs on Camel components, then browse github pages at: https://github.com/apache/camel/blob/master/components/camel-seda/src/main/docs/seda-component.adoc

Those docs are up to date and show both component vs endpoint options in different tables, so its easier to know the difference.

Answer 2

For those who have the same question, this is how i use the queueSize now

Initialize a new seda component,

SedaComponent sedaComponent = new SedaComponent();
        sedaComponent.setQueueSize(3);
        context.addComponent("sedaComponent", sedaComponent);

then use this component at the route like,

from("seda:someEndPoint?concurrentConsumers=5")
                             .to("sedaComponent:someOtherSedaEndPoint?blockWhenFull=true");