activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Christian Posta <christian.po...@gmail.com>
Subject Re: Starting with AMQ+AMQP 1.0+QPID Proton
Date Mon, 08 Jul 2013 17:01:09 GMT
Pablo,

You should be able to specify jms-like selectors.
It's not going to work by specifying it on the transport connector.
You would specify it in a 'jms-selector' header when your consumer connects
up. Can you show the code your consumer uses?


On Mon, Jul 8, 2013 at 12:20 PM, Pablo Rodríguez Rey <mr@xkr.es> wrote:

> I reply you between lines.
>
> On Mon, Jul 8, 2013 at 6:01 PM, Gordon Sim <gsim@redhat.com> 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:
> >>
> >> https://svn.apache.org/repos/**asf/qpid/trunk/qpid/specs/**
> >> apache-filters.xml#type-**selector-filter<
> 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...
> >
> >
> Yes, I know it's an apache proposal for AMQP.
>
>
> >
> >  http://activemq.apache.org/**amqp.html<
> http://activemq.apache.org/amqp.html>
> >> https://cwiki.apache.org/**confluence/display/ACTIVEMQ/**AMQP<
> 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<
> http://127.0.0.1/route?header.priority=5>
> >> amqp://127.0.0.1/route?header.**priority%3E5<
> http://127.0.0.1/route?header.priority%3E5>
> >> amqp://127.0.0.1/route?**transport.transformer=jms&**priority=E5<
> http://127.0.0.1/route?transport.transformer=jms&priority=E5>
> >> amqp://127.0.0.1/route?**transport.transformer=jms&**priority%3E5<
> http://127.0.0.1/route?transport.transformer=jms&priority%3E5>
> >> amqp://127.0.0.1/route?**transport.transformer=jms&**header.priority=E5
> <http://127.0.0.1/route?transport.transformer=jms&header.priority=E5>
> >> amqp://
> 127.0.0.1/route?**transport.transformer=jms&**header.priority%3E5<
> http://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.
> >
> >
> 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.
>
> Thanks.
>
>
> --
> Pablo Rodríguez Rey (http://mr.xkr.es)
> 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"
>



-- 
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta

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