I was able to verify that this works:
./drain -f "directqueue; {create:receiver,
node:{x-declare:{arguments:{'qpid.policy_type':ring,
'qpid.max_size':500000000}},x-bindings:[{exchange:'amq.direct',queue:'directqueue',key:'mykey'}]}}"
./spout --content "testcontent" --property "testkey=testval"
amq.direct/mykey
I get the message:
Message(properties={qpid.subject:mykey,
spout-id:77d96e09-5088-4f80-a624-86b132a8d49e:0, testkey:testval,
x-amqp-0-10.routing-key:mykey}, content='testcontent')
But it doesn't work if I use "amq.direct" in spout, so I think I need the
"/mykey". Something to do with the routing key as the fanout exchange
didn't need that.
Given that, I tried updating the test to use the routing key, but still no
luck:
./spout --content "testcontent" --property "testkey=testval" amq.match/data1
./drain -f "testqueue; {create:receiver,
node:{x-declare:{arguments:{'qpid.policy_type':ring,
'qpid.max_size':500000000}},x-bindings:[{exchange:'amq.match',queue:'testqueue',key:'data1',arguments:{x-match:all,testkey:testval}}]}}"
--
View this message in context:
http://qpid.2158936.n2.nabble.com/Headers-message-filtering-tp7181185p7181770.html
Sent from the Apache Qpid users mailing list archive at Nabble.com.
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
