QPID-4948: enable browsing

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

1 files changed, 22 insertions, 0 deletions

diff --git a/qpid/tests/src/py/qpid_tests/broker_1_0/general.py b/qpid/tests/src/py/qpid_tests/broker_1_0/general.py
index b3ff1df5a1..3b48a78718 100644
--- a/qpid/tests/src/py/qpid_tests/broker_1_0/general.py
+++ b/qpid/tests/src/py/qpid_tests/broker_1_0/general.py
@@ -44,3 +44,25 @@ class GeneralTests (VersionTest):
         assert response.content == "response" and response.correlation_id == "a1", response
 
         self.ssn.acknowledge()
+
+
+    def test_browse(self):
+        snd = self.ssn.sender("#")
+        rcv = self.ssn.receiver("%s; {mode: browse}" % snd.target)
+
+        msgs = [Message(content=s, subject = s) for s in ['a','b','c','d']]
+
+        for m in msgs: snd.send(m)
+
+        for expected in msgs:
+            msg = rcv.fetch(0)
+            assert msg.content == expected.content
+            self.ssn.acknowledge(msg)
+        rcv.close()
+
+        rcv = self.ssn.receiver(snd.target)
+        for expected in msgs:
+            msg = rcv.fetch(0)
+            assert msg.content == expected.content
+            self.ssn.acknowledge(msg)
+