From 0333573627c831142aa251bfb1cabdb1e2bf438e Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Tue, 20 May 2008 13:44:34 +0000 Subject: Support for AMQP 0-10 sessions in C++ broker. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@658246 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/tests/federation.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'cpp/src/tests/federation.py') diff --git a/cpp/src/tests/federation.py b/cpp/src/tests/federation.py index 98e34be0e9..0f52165587 100755 --- a/cpp/src/tests/federation.py +++ b/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"] -- cgit v1.2.1