summaryrefslogtreecommitdiff
path: root/qpid/cpp/src/tests/federation.py
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2008-05-20 13:44:34 +0000
committerAlan Conway <aconway@apache.org>2008-05-20 13:44:34 +0000
commit5bb0604473b2367218c297927d578d19951ed775 (patch)
treeaa547f81ad68be2293ce2deab826c026e292f59a /qpid/cpp/src/tests/federation.py
parentfab61022ef0d7cc2afcca699e35c8b95c9141b38 (diff)
downloadqpid-python-5bb0604473b2367218c297927d578d19951ed775.tar.gz
Support for AMQP 0-10 sessions in C++ broker.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@658246 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/tests/federation.py')
-rwxr-xr-xqpid/cpp/src/tests/federation.py8
1 files changed, 4 insertions, 4 deletions
diff --git a/qpid/cpp/src/tests/federation.py b/qpid/cpp/src/tests/federation.py
index 98e34be0e9..0f52165587 100755
--- a/qpid/cpp/src/tests/federation.py
+++ b/qpid/cpp/src/tests/federation.py
@@ -57,7 +57,7 @@ def remote_port():
class Helper:
def __init__(self, parent):
self.parent = parent
- self.session = parent.conn.session("2")
+ self.session = parent.conn.session("Helper")
self.mc = managementClient(self.session.spec)
self.mch = self.mc.addChannel(self.session)
self.mc.syncWaitForStable(self.mch)
@@ -126,7 +126,7 @@ class FederationTests(TestBase010):
#send messages to remote broker and confirm it is routed to local broker
r_conn = self.connect(host=remote_host(), port=remote_port())
- r_session = r_conn.session("1")
+ r_session = r_conn.session("test_pull_from_exchange")
for i in range(1, 11):
dp = r_session.delivery_properties(routing_key="my-key")
@@ -153,7 +153,7 @@ class FederationTests(TestBase010):
#setup queue on remote broker and add some messages
r_conn = self.connect(host=remote_host(), port=remote_port())
- r_session = r_conn.session("1")
+ r_session = r_conn.session("test_pull_from_queue")
r_session.queue_declare(queue="my-bridge-queue", exclusive=True, auto_delete=True)
for i in range(1, 6):
dp = r_session.delivery_properties(routing_key="my-bridge-queue")
@@ -223,7 +223,7 @@ class FederationTests(TestBase010):
#send messages to remote broker and confirm it is routed to local broker
r_conn = self.connect(host=remote_host(), port=remote_port())
- r_session = r_conn.session("1")
+ r_session = r_conn.session("test_tracing")
trace = [None, "exclude-me", "a,exclude-me,b", "also-exclude-me,c", "dont-exclude-me"]
body = ["yes", "first-bad", "second-bad", "third-bad", "yes"]