diff options
Diffstat (limited to 'qpid/python/qpid/tests/messaging.py')
| -rw-r--r-- | qpid/python/qpid/tests/messaging.py | 22 |
1 files changed, 22 insertions, 0 deletions
diff --git a/qpid/python/qpid/tests/messaging.py b/qpid/python/qpid/tests/messaging.py index ce1302a4d6..ca35c56166 100644 --- a/qpid/python/qpid/tests/messaging.py +++ b/qpid/python/qpid/tests/messaging.py @@ -580,6 +580,22 @@ class ReceiverTests(Base): # XXX: need testClose + def testMode(self): + msgs = [self.content("testMode", 1), + self.content("testMode", 2), + self.content("testMode", 3)] + + for m in msgs: + self.snd.send(m) + + rb = self.ssn.receiver('test-receiver-queue; {mode: browse}') + rc = self.ssn.receiver('test-receiver-queue; {mode: consume}') + self.drain(rb, expected=msgs) + self.drain(rc, expected=msgs) + rb2 = self.ssn.receiver(rb.source) + self.assertEmpty(rb2) + self.drain(self.rcv, expected=[]) + class AddressTests(Base): def setup_connection(self): @@ -846,6 +862,12 @@ class AddressErrorTests(Base): self.receiverErrorTest(UNLEXABLE_ADDR, ReceiveError, lambda e: "unrecognized characters" in str(e)) + def testInvalidMode(self): + # XXX: should have specific exception for this + self.receiverErrorTest('name; {mode: "this-is-a-bad-receiver-mode"}', + ReceiveError, + lambda e: "not in ('browse', 'consume')" in str(e)) + SENDER_Q = 'test-sender-q; {create: always, delete: always}' class SenderTests(Base): |