diff options
author | Rafael H. Schloming <rhs@apache.org> | 2010-01-19 21:29:33 +0000 |
---|---|---|
committer | Rafael H. Schloming <rhs@apache.org> | 2010-01-19 21:29:33 +0000 |
commit | 89e6f4eea1d172046c806ca3c01244bb0b9cfeee (patch) | |
tree | dac0125945c56e9a8a62406c6d180cf7735014a8 /python/qpid/tests/messaging.py | |
parent | 07b7a61c7876b92b6ea0d6355d97cae4437df5c2 (diff) | |
download | qpid-python-89e6f4eea1d172046c806ca3c01244bb0b9cfeee.tar.gz |
fixed bug in destination/receiver correlation
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@900967 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python/qpid/tests/messaging.py')
-rw-r--r-- | python/qpid/tests/messaging.py | 22 |
1 files changed, 22 insertions, 0 deletions
diff --git a/python/qpid/tests/messaging.py b/python/qpid/tests/messaging.py index f2a270192e..9a8a4c807c 100644 --- a/python/qpid/tests/messaging.py +++ b/python/qpid/tests/messaging.py @@ -541,6 +541,28 @@ class ReceiverTests(Base): self.ssn.acknowledge() + def testDoubleClose(self): + m1 = self.content("testDoubleClose", 1) + m2 = self.content("testDoubleClose", 2) + + snd = self.ssn.sender("""test-double-close; { + create: always, + delete: sender, + node-properties: { + type: topic + } +} +""") + r1 = self.ssn.receiver(snd.target) + r2 = self.ssn.receiver(snd.target) + snd.send(m1) + self.drain(r1, expected=[m1]) + self.drain(r2, expected=[m1]) + r1.close() + snd.send(m2) + self.drain(r2, expected=[m2]) + r2.close() + # XXX: need testClose class AddressTests(Base): |