QPID-6714: support for JMS header names in selectors, plus support for to, replyto and subject

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1698426 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 22 insertions, 0 deletions

diff --git a/qpid/tests/src/py/qpid_tests/broker_1_0/selector.py b/qpid/tests/src/py/qpid_tests/broker_1_0/selector.py
index ac2bbd8db3..323baaab07 100644
--- a/qpid/tests/src/py/qpid_tests/broker_1_0/selector.py
+++ b/qpid/tests/src/py/qpid_tests/broker_1_0/selector.py
@@ -71,3 +71,25 @@ class SelectorTests (VersionTest):
         msg = rcv_4.fetch(0)
         assert msg.content == 'd'
         self.ssn.acknowledge(msg)
+
+    def check_selected(self,node, selector, expected_content):
+        rcv = self.ssn.receiver("%s; {mode:browse, link:{selector:\"%s\"}}" % (node, selector))
+        msg = rcv.fetch(0)
+        assert msg.content == expected_content, msg
+        rcv.close()
+
+    def test_jms_header_names(self):
+        """
+        The new AMQP 1.0 based JMS client uses these rather than the special names above
+        """
+        msgs = [Message(content=i, id=i, correlation_id=i, subject=i, priority=p+1, reply_to=i, properties={'x-amqp-to':i}) for p, i in enumerate(['a', 'b', 'c', 'd'])]
+
+        snd = self.ssn.sender("#")
+        for m in msgs: snd.send(m)
+
+        self.check_selected(snd.target, "JMSMessageID = 'a'", 'a')
+        self.check_selected(snd.target, "JMSCorrelationID = 'b'", 'b')
+        self.check_selected(snd.target, "JMSPriority = 3", 'c')
+        self.check_selected(snd.target, "JMSDestination = 'a'", 'a')
+        self.check_selected(snd.target, "JMSReplyTo = 'b'", 'b')
+        self.check_selected(snd.target, "JMSType = 'c'", 'c')