From c29ed9b3d6d5bc2f772b7700166fa11d138ae3ec Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Wed, 28 Aug 2013 12:41:23 +0000 Subject: QPID-4948: enable browsing git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1518181 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/tests/src/py/qpid_tests/broker_1_0/general.py | 22 ++++++++++++++++++++++ 1 file changed, 22 insertions(+) (limited to 'qpid/tests/src/py') 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) + -- cgit v1.2.1