diff options
author | Alan Conway <aconway@apache.org> | 2008-05-20 13:44:34 +0000 |
---|---|---|
committer | Alan Conway <aconway@apache.org> | 2008-05-20 13:44:34 +0000 |
commit | 0333573627c831142aa251bfb1cabdb1e2bf438e (patch) | |
tree | 953bf8c624374c57953aa3f2888254d175609d9a /cpp/src/tests/federation.py | |
parent | 96024622ccfcc8fdd24b3c9ace44f7c8849fac46 (diff) | |
download | qpid-python-0333573627c831142aa251bfb1cabdb1e2bf438e.tar.gz |
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
Diffstat (limited to 'cpp/src/tests/federation.py')
-rwxr-xr-x | cpp/src/tests/federation.py | 8 |
1 files changed, 4 insertions, 4 deletions
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"] |