Hi all,
I am a user of activemq 5.9, and CMS to send:reply message, It's working
fine.
So now I want to send and receive message but with amqp protocol, I would
like to use qpid proton (0.8)
and do the same things, like CMS filtering message on the correlationId, or
another string.
I read this:
https://svn.apache.org/repos/asf/qpid/trunk/qpid/specs/apache-filters.xml#type-selector-filter
but ....
With qpid proton, to recieve any message without filtering, it's working
perfectly, if I want to filter my message (receiver), here beginning
problems..
I saw on the debug log of ActiveMq (I activate the connector amqp+jms)
<transportConnector name="amqp+nio"
uri="amqp+nio://localhost:5672?transport.transformer=jms"/>
Here my trace:
2014-11-12 10:15:20,524 | DEBUG | trace 394 |
100 - org.apache.activemq.activemq-osgi - 5.9.0 | IN: CH[0]
: Attach{name='receiver-xxx', handle=0, role=RECEIVER,
sndSettleMode=UNSETTLED, rcvSettleMode=SECOND,
source=Source{address='queue://myQueue', durable=NONE,
expiryPolicy=SESSION_END, timeout=0, dynamic=false,
dynamicNodeProperties=null, distributionMode=null, filter=null,
defaultOutcome=null, outcomes=null, capabilities=null},
target=Target{address='queue://myQueue', durable=NONE,
expiryPolicy=SESSION_END, timeout=0, dynamic=false,
dynamicNodeProperties=null, capabilities=null}, unsettled=null,
incompleteUnsettled=false, initialDeliveryCount=0, maxMessageSize=null,
offeredCapabilities=null, desiredCapabilities=null, properties=null}
Anybody have a snippet code to implement this pattern, request/reply with a
filtering on correlationId, or any filter???
any help will be appreciate
thanks you
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Filtering-message-with-Qpid-Proton-reciever-tp4687359.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
