diff options
author | Ask Solem <ask@celeryproject.org> | 2013-06-25 11:03:50 +0100 |
---|---|---|
committer | Ask Solem <ask@celeryproject.org> | 2013-06-25 11:03:50 +0100 |
commit | 5c0b9774ff7ae6afccadef2038df2e6387eb325f (patch) | |
tree | f1a77ed43bbba2929a2d2608dda1319175dd1fac /kombu/transport/pyamqp.py | |
parent | 55d000019289be3ac9b38261a01cb57dcadbc432 (diff) | |
download | kombu-5c0b9774ff7ae6afccadef2038df2e6387eb325f.tar.gz |
cosmetics
Diffstat (limited to 'kombu/transport/pyamqp.py')
-rw-r--r-- | kombu/transport/pyamqp.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/kombu/transport/pyamqp.py b/kombu/transport/pyamqp.py index b87fa379..e45eab5e 100644 --- a/kombu/transport/pyamqp.py +++ b/kombu/transport/pyamqp.py @@ -79,14 +79,14 @@ class Transport(base.Transport): recoverable_channel_errors = amqp.Connection.recoverable_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 create_channel(self, connection): return connection.channel() |