summaryrefslogtreecommitdiff
path: root/python/qpid/tests/messaging.py
diff options
context:
space:
mode:
authorRafael H. Schloming <rhs@apache.org>2009-12-17 04:58:31 +0000
committerRafael H. Schloming <rhs@apache.org>2009-12-17 04:58:31 +0000
commit9c5549a09d261f3a66ce569560af7baf14d48d25 (patch)
tree18b93d3f4fe96c7ef589d457d3b2159eb73ce050 /python/qpid/tests/messaging.py
parent6f485818cbf237cdcd6fd3bfc7215b61f3656e14 (diff)
downloadqpid-python-9c5549a09d261f3a66ce569560af7baf14d48d25.tar.gz
QPID-2287: added an address option for declaring queues with multiple bindings
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@891537 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 cbfbc5a56d..f2a270192e 100644
--- a/python/qpid/tests/messaging.py
+++ b/python/qpid/tests/messaging.py
@@ -642,6 +642,28 @@ class AddressTests(Base):
# XXX: need to figure out close after error
self.conn._remove_session(self.ssn)
+ def testBindings(self):
+ snd = self.ssn.sender("""
+test-bindings-queue; {
+ create: always,
+ delete: always,
+ node-properties: {
+ x-properties: {
+ bindings: ["amq.topic/a.#", "amq.direct/b", "amq.topic/c.*"]
+ }
+ }
+}
+""")
+ snd.send("one")
+ snd_a = self.ssn.sender("amq.topic/a.foo")
+ snd_b = self.ssn.sender("amq.direct/b")
+ snd_c = self.ssn.sender("amq.topic/c.bar")
+ snd_a.send("two")
+ snd_b.send("three")
+ snd_c.send("four")
+ rcv = self.ssn.receiver("test-bindings-queue")
+ self.drain(rcv, expected=["one", "two", "three", "four"])
+
NOSUCH_Q = "this-queue-should-not-exist"
UNPARSEABLE_ADDR = "name/subject; {bad options"
UNLEXABLE_ADDR = "\0x0\0x1\0x2\0x3"