Scratch my last comment Gordon I tried this again and realised what I'd
done....
I had started my consumer with x-match: all in the address (my consumer
queues stay up until deleted) 'cause x-match: all failed to deliver anything
I'd forgotten this when I tried again with x-match: any
so trying x-match all followed by x-match any and forgetting to delete the
x-match: all binding gave 1666 messages where I'd expect 1000 - it's weird
as x-match: all on its own fails to deliver anything.
This case seems to have forwarded a message for each binding so I get 1000
messages related to data-service=item-selection and 666 relating to
item-owner=fadams which relates to the line in the producer below
if ((i % 3) == 0) message.setStringProperty("item-owner", "jdadams");
else message.setStringProperty("item-owner", "fadams");
Although this is different to Richard's scenario it's still rather weird and
as this is forwarding messages separately for each match this could actually
be a similar issue to the one Richard has seen as his two consumers would
each add a binding. BTW my scenario was repeatable whether or not I included
a binding key.
Another thing I noted was that if I bound the consumer to the destination
broker before I created the dynamic route the binding doesn't get propagated
to the source broker. I'd have expected all existing bindings to be
propagated as well as newly added ones - this feels like another bug?
looks like I'm sticking with queue routes for headers exchange federation
for the forseeable :-)
Regards,
Fraser
fadams wrote:
>
> Hi Gordon,
> I tried this independently and this is just to report I get the same
> results as Richard.
>
> I had a consumer with an address
>
> "myqueue; {create: receiver, node: {x-declare: {arguments:
> {'qpid.policy_type': ring, 'qpid.max_size': 500000000}}, x-bindings:
> [{exchange: 'amq.match', queue: 'myqueue', key: 'data1', arguments:
> {x-match: any, data-service: item-selection, item-owner: fadams}}]}}"
>
>
>
--
View this message in context:
http://apache-qpid-users.2158936.n2.nabble.com/Dynamic-Routes-and-Duplicate-Messages-tp6562267p6591836.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]
