diff options
| author | Gordon Sim <gsim@apache.org> | 2013-08-13 15:06:54 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2013-08-13 15:06:54 +0000 |
| commit | d14006009ba25fe9ed62077b942dafb8564a28c7 (patch) | |
| tree | 9e09b77a36ff2e77415d164596ec48ce913f0200 /python | |
| parent | 592e3317e4277cc469b0bdc29f4e809c1b639d07 (diff) | |
| download | qpid-python-d14006009ba25fe9ed62077b942dafb8564a28c7.tar.gz | |
QPID-4711: translate between structured content in AMQP 0-10 and 1.0
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1513537 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python')
| -rw-r--r-- | python/qpid/tests/messaging/__init__.py | 13 |
1 files changed, 13 insertions, 0 deletions
diff --git a/python/qpid/tests/messaging/__init__.py b/python/qpid/tests/messaging/__init__.py index 5c9cdf2f27..38a5b066d6 100644 --- a/python/qpid/tests/messaging/__init__.py +++ b/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 |