camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Charles Moulliard <cmoulli...@gmail.com>
Subject Re: good solution to work with jms message priority
Date Fri, 04 Jun 2010 11:39:12 GMT
Hi Christian,

As the two routes will create JMS concurrent consumers on the queue
'queue:inbox' with the same consumer.priority, I don't think that
messages with priority > 4 will be processed before the others as the
messages created by camel during the exchange will be send to the same
endpoint "direct:inbox" and then we will have a mix between messages
with different priority.

As mentioned by Claus, EIP resequencer is the only scenario
interesting and selector are very slow on ActiveMQ.

KR,

Charles Moulliard

Senior Enterprise Architect (J2EE, .NET, SOA)
Apache Camel/ServiceMix Committer

*******************************************************************
- Blog : http://cmoulliard.blogspot.com
- Twitter : http://twitter.com/cmoulliard
- Linkedlin : http://www.linkedin.com/in/charlesmoulliard



On Fri, Jun 4, 2010 at 1:20 PM, Christian Mueller
<christian.mueller@gmail.com> wrote:
>
> Hello list,
>
> I have a requirement to process online (coming from an external web service)
> and batch (several thousand) messages. The online messages are more prior
> (the customer is waiting of the response) and should be processed before the
> batch messages (I think a common requirement). Because ActiveMQ at this time
> doesn't support message priority
> ([how-can-i-support-priority-queues|http://activemq.apache.org/how-can-i-support-priority-queues.html]),
> I was looking for another solution. I read this thread
> [Camel-and-jms-priority|http://old.nabble.com/Camel-and-jms-priority-ts25962858.html#a25962858]
> and found it to complicated - I'm lasy... :-)
>
> My question is, would this Camel route also do a good job for this
> requirements?
>
> {code}
> from("activemq://queue:inbox?concurrentConsumers=5&selector=priority<='4'")
> .to("direct:inbox");
>
> from("activemq://queue:inbox?concurrentConsumers=5&selector=priority>'4'")
> .to("direct:inbox");
>
> from("direct:inbox")
> .processRef("myProcessor")
> .to("activemq://queue:outbox");
> {code}
>
> Thanks in advanced,
> Christian
> --
> View this message in context: http://old.nabble.com/good-solution-to-work-with-jms-message-priority-tp28778639p28778639.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>
>

Mime
View raw message