From d30253ae61bb81090ba43b055094dbe5a6d7c98d Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Tue, 13 Aug 2013 15:06:54 +0000 Subject: QPID-4711: translate between structured content in AMQP 0-10 and 1.0 git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1513537 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/python/qpid/tests/messaging/__init__.py | 13 +++++++++++++ 1 file changed, 13 insertions(+) (limited to 'qpid/python') diff --git a/qpid/python/qpid/tests/messaging/__init__.py b/qpid/python/qpid/tests/messaging/__init__.py index 5c9cdf2f27..38a5b066d6 100644 --- a/qpid/python/qpid/tests/messaging/__init__.py +++ b/qpid/python/qpid/tests/messaging/__init__.py @@ -188,4 +188,17 @@ class Base(Test): return {"reconnect": self.reconnect(), "transport": self.transport()} +class VersionTest (Base): + def create_connection(self, version="amqp1.0", force=False): + opts = self.connection_options() + if force or not 'protocol' in opts: + opts['protocol'] = version; + return Connection.establish(self.broker, **opts) + + def setup_connection(self): + return self.create_connection() + + def setup_session(self): + return self.conn.session() + import address, endpoints, message -- cgit v1.2.1