camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Christian Schneider <ch...@die-schneider.net>
Subject Re: Instead of parallel JMS consumption only sequentially processed
Date Fri, 25 Nov 2016 10:07:23 GMT
I added a note at camel-jms so people find this quicker in the future.

Christian

On 24.11.2016 17:20, Claus Ibsen wrote:
> Set a lower prefetch buffer on ActiveMQ as each consumer polls in 1000
> messages by default.
>
> On Thu, Nov 24, 2016 at 2:54 PM, Oliver Wulff <owulff@talend.com> wrote:
>> Hi there
>>
>>
>> I've deployed a camel route in Karaf 4.0.3 which is configured to consume
>> JMS messages in parallel (concurrentConsumers=2, maxConcurrentConsumers=6).
>> But Camel consumes the messages sequentially only. I've created a testcase
>> which depends on a ConnectionFactory managed by Karaf (MOM, ActiveMQ). The
>> testcase contains two routes. The route 'jms-produce' produces jms messages
>> every 200ms whereas 'jms-consume' consumes the messages with a delay of 5
>> seconds. The testcase illustrates that messages are processed sequentially.
>>
>>
>> 2016-11-24 14:36:57,696 | INFO  | nsole user karaf | OsgiSpringCamelContext
>> | 161 - org.apache.camel.camel-core - 2.15.4 | Route: jms-consume started
>> and consuming from:
>> Endpoint[jms://queue:TEST?concurrentConsumers=2&maxConcurrentConsumers=6]
>> 2016-11-24 14:36:57,756 | INFO  | msConsumer[TEST] | jms-consume
>> | 161 - org.apache.camel.camel-core - 2.15.4 | JMS message consumed
>> ID-ubuntu-wuol-49091-1479978003649-7-297
>> 2016-11-24 14:37:02,761 | INFO  | msConsumer[TEST] | jms-consume
>> | 161 - org.apache.camel.camel-core - 2.15.4 | JMS message successfully
>> processed ID-ubuntu-wuol-49091-1479978003649-7-297
>> 2016-11-24 14:37:02,763 | INFO  | msConsumer[TEST] | jms-consume
>> | 161 - org.apache.camel.camel-core - 2.15.4 | JMS message consumed
>> ID-ubuntu-wuol-49091-1479978003649-7-298
>> 2016-11-24 14:37:07,764 | INFO  | msConsumer[TEST] | jms-consume
>> | 161 - org.apache.camel.camel-core - 2.15.4 | JMS message successfully
>> processed ID-ubuntu-wuol-49091-1479978003649-7-298
>> 2016-11-24 14:37:07,766 | INFO  | msConsumer[TEST] | jms-consume
>> | 161 - org.apache.camel.camel-core - 2.15.4 | JMS message consumed
>> ID-ubuntu-wuol-49091-1479978003649-7-299
>> 2016-11-24 14:37:12,770 | INFO  | msConsumer[TEST] | jms-consume
>> | 161 - org.apache.camel.camel-core - 2.15.4 | JMS message successfully
>> processed ID-ubuntu-wuol-49091-1479978003649-7-299
>> 2016-11-24 14:37:12,772 | INFO  | msConsumer[TEST] | jms-consume
>> | 161 - org.apache.camel.camel-core - 2.15.4 | JMS message consumed
>> ID-ubuntu-wuol-49091-1479978003649-7-300
>> 2016-11-24 14:37:17,775 | INFO  | msConsumer[TEST] | jms-consume
>> | 161 - org.apache.camel.camel-core - 2.15.4 | JMS message successfully
>> processed ID-ubuntu-wuol-49091-1479978003649-7-300
>> 2016-11-24 14:37:17,777 | INFO  | msConsumer[TEST] | jms-consume
>> | 161 - org.apache.camel.camel-core - 2.15.4 | JMS message consumed
>> ID-ubuntu-wuol-49091-1479978003649-7-301
>>
>> What am I doing wrong? Thanks for any hints.
>>
>>
>> Thanks
>>
>> Oli
>
>


-- 
Christian Schneider
http://www.liquid-reality.de

Open Source Architect
http://www.talend.com


Mime
View raw message