amqp — archive

Correct behavior for link source with filters applied?

From: Rob Godfrey <[email protected]>
To: [email protected]
Date: Thu, 21 Feb 2019 16:43:00 -0000

On Thu, 21 Feb 2019 at 16:23, Clemens Vasters < [email protected] > wrote: The core spec is silent on what the expected behavior is for links with applied filters. I m looking at wire traces of Qpid JMS interacting with ActiveMQ during the Qpid JMS tests and there specifically at this here: https://github.com/apache/qpid-jms/blob/master/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/consumer/JmsMessageConsumerTest.java#L341 The runtime behavior with the queue appears to be that ActiveMQ instantly skips messages that don t match the given filter and doesn t block on a message that s ahead of messages matching the filter. Doesn t that imply that the filter is used as a feature of the backend rather than of the link, i.e. the queue acting like a topic rather than a queue? The spec is (rightly, I think) silent on this. All the spec says is that messages that do not meet the filter do not pass through it. I think it is an implementation decision as to whether a message that does not pass the filter "blocks" the filter, or still allows others to pass through. From a JMS perspective the expectation is that a selector only picks off messages that match the selector and does not cause the consumer to block until the head of the queue has a message which matches. For a queue, I would expect that competing consumers become eligible for getting a message when it is their turn, and then there s a decision for whether that message is indeed transferred based on the filter and otherwise that consumer yields its turn. In this particular test, the queue should therefore block. Again, an implementation decision (as are notions like "turn"). I believe the spec also says nothing about message ordering (terms like queue are not defined... nodes could be unordered bags of messages). Thoughts? -- Rob -- ______________________________ ______________________________ _________________ Red Hat GmbH, www.de.redhat.com , Registered seat: Grasbrunn, Commercial register: Amtsgericht Muenchen, HRB 153243, Managing Directors: ,Charles Cachera, Michael Cunningham, Michael O'Neill, Eric Shander