[CAMEL-10677] SJMSBatchConsumer does not respect the consumerCount parameter

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 2.19.0
• Fix Version/s: 2.18.2, 2.19.0
• Component/s: camel-sjms
• Estimated Complexity: Unknown
• Assignee: Claus Ibsen
• Reporter: Christ Taylor
• Created: 05/Jan/17 19:36
• Updated: 09/Jan/17 13:01
• Resolved: 09/Jan/17 13:01

Description

The following route does not create 20 consumers in my queue.

Route

// #myStrategy is an instance of GroupedExchangeAggregationStrategy
    from("sjms-batch:TEST.FOO?aggregationStrategy=#myStrategy&consumerCount=20")
     .to("stream:out").routeId("myrouteid")

When I start the application, I get a couple of NullPointerException.
usually, the resulting consumerCount that I see in my queue can be computed as:

consumerCount

resulting consumerCount = (configured consumerCount - number of NPE at startup)

Here the exception:

Stacktrace

[error] java.lang.NullPointerException
[error]         at org.apache.camel.component.sjms.batch.SjmsBatchConsumer$BatchConsumptionLoop.run(SjmsBatchConsumer.java:302)
[error]         at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
[error]         at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
[error]         at java.lang.Thread.run(Thread.java:745)