activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Pablo Rodríguez Rey>
Subject Re: Starting with AMQ+AMQP 1.0+QPID Proton
Date Mon, 08 Jul 2013 16:20:23 GMT
I reply you between lines.

On Mon, Jul 8, 2013 at 6:01 PM, Gordon Sim <> wrote:

> On 07/05/2013 03:30 PM, Pablo Rodríguez Rey wrote:
>> Also, I've a question about mixing AMQP 1.0 Filters/Selectors. I don't
>> know
>> how to make a selector for filtering the Priority of a message. I have a
>> cluster of 6 machines with 3 workers each. 2 are low-priority workers and
>> can do any video transcode work with any priority, and 1 reserved worker
>> with higher priority only for user-time transcoding.
>> I've seen these pages:
>> apache-filters.xml#type-**selector-filter<>
> Note that the selector filter described there is an extension to the core
> AMQP 1.0 protocol...
Yes, I know it's an apache proposal for AMQP.

>> I can send and receive messages using AMQP URLs:
>> amqp://
>> But I dont know how to set the paramers to active the selector/filters for
>> selecting only messages with priority=5 or priority>5 (examples), tried a
>> lot of combinations:
>> amqp://**priority=5<>
>> amqp://**priority%3E5<>
>> amqp://**transport.transformer=jms&**priority=E5<>
>> amqp://**transport.transformer=jms&**priority%3E5<>
>> amqp://**transport.transformer=jms&**header.priority=E5<>
>> amqp://**transport.transformer=jms&**header.priority%3E5<>
>> ...
> First, I don't believe the the Qpid Proton Messenger API (which I assume
> from the subject is what you are using?) provides any way to set a filter
> on attach.
In deed, there is no Proton API for doing that, so I guessed it will be
only available using parameters in AMQP address.

> Second, though I could be wrong as I too am new to ActiveMQ, it also looks
> like the AMQP transport for ActiveMQ does not support the selector filter
> extension(?). Certainly in my experiments it doesn't apply any filtering.

I don't know so, I did several trys but the only thing I need to do is find
in the source code of ActiveMQ.


Pablo Rodríguez Rey (
Area de Tecnologías de la Información y las Comunicaciones Aplicadas
Edificio ATICA ~ Sección de Redes ~ Despacho B1.2.004 ~ Tel. 868 88 8209
Universidad de Murcia, 30100 Campus de Espinardo (Murcia - Spain)
"i've mapped my mind on my dick"

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message