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:
https://svn.apache.org/repos/asf/qpid/trunk/qpid/specs/apache-filters.xml#type-selector-filter
Note that the selector filter described there is an extension to the
core AMQP 1.0 protocol...
http://activemq.apache.org/amqp.html
https://cwiki.apache.org/confluence/display/ACTIVEMQ/AMQP
I can send and receive messages using AMQP URLs:
amqp://127.0.0.1/route
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://127.0.0.1/route?header.priority=5
amqp://127.0.0.1/route?header.priority%3E5
amqp://127.0.0.1/route?transport.transformer=jms&priority=E5
amqp://127.0.0.1/route?transport.transformer=jms&priority%3E5
amqp://127.0.0.1/route?transport.transformer=jms&header.priority=E5
amqp://127.0.0.1/route?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.
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.
