From 1afd4baea2a3c38feb14dcb71678eb69d1f0c8b4 Mon Sep 17 00:00:00 2001 From: Ask Solem Date: Fri, 16 Aug 2013 17:29:59 +0100 Subject: pyamqp now implements driver_version --- kombu/transport/pyamqp.py | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/kombu/transport/pyamqp.py b/kombu/transport/pyamqp.py index 7fbd31b0..8b066e7b 100644 --- a/kombu/transport/pyamqp.py +++ b/kombu/transport/pyamqp.py @@ -75,14 +75,17 @@ class Transport(base.Transport): channel_errors = (StdChannelError, ) + amqp.Connection.channel_errors nb_keep_draining = True - driver_name = "py-amqp" - driver_type = "amqp" + driver_name = 'py-amqp' + driver_type = 'amqp' supports_heartbeats = True supports_ev = True def __init__(self, client, **kwargs): self.client = client - self.default_port = kwargs.get("default_port") or self.default_port + self.default_port = kwargs.get('default_port') or self.default_port + + def driver_version(self): + return amqp.__version__ def create_channel(self, connection): return connection.channel() -- cgit v1.2.1