QPID-5503: expose next_receiver through swig wrapper, add test for both 1.0 and 0-10

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

1 files changed, 19 insertions, 0 deletions

diff --git a/qpid/tests/src/py/qpid_tests/broker_0_10/new_api.py b/qpid/tests/src/py/qpid_tests/broker_0_10/new_api.py
index 57da368ff5..617f1ab666 100644
--- a/qpid/tests/src/py/qpid_tests/broker_0_10/new_api.py
+++ b/qpid/tests/src/py/qpid_tests/broker_0_10/new_api.py
@@ -123,6 +123,25 @@ class GeneralTests(Base):
 
         sess4.close()
 
+    def test_next_receiver(self):
+        keys = ["a", "b", "c"]
+        receivers = [self.ssn.receiver("amq.direct/%s" % k) for k in keys]
+        for r in receivers:
+            r.capacity = 10
+
+        snd = self.ssn.sender("amq.direct")
+
+        for k in keys:
+            snd.send(Message(subject=k, content=k))
+
+        expected = keys
+        while len(expected):
+            rcv = self.ssn.next_receiver(timeout=self.delay())
+            c = rcv.fetch().content
+            assert c in expected
+            expected.remove(c)
+        self.ssn.acknowledge()
+
 class SequenceNumberTests(Base):
     """
     Tests of ring queue sequence number