diff options
Diffstat (limited to 'qpid/tests')
| -rw-r--r-- | qpid/tests/src/py/qpid_tests/broker_1_0/general.py | 22 |
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) + |
