summaryrefslogtreecommitdiff
path: root/python/qpid/tests/messaging.py
diff options
context:
space:
mode:
authorRafael H. Schloming <rhs@apache.org>2010-01-19 21:29:33 +0000
committerRafael H. Schloming <rhs@apache.org>2010-01-19 21:29:33 +0000
commit89e6f4eea1d172046c806ca3c01244bb0b9cfeee (patch)
treedac0125945c56e9a8a62406c6d180cf7735014a8 /python/qpid/tests/messaging.py
parent07b7a61c7876b92b6ea0d6355d97cae4437df5c2 (diff)
downloadqpid-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.py22
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):