summaryrefslogtreecommitdiff
path: root/kombu/transport/pyamqp.py
diff options
context:
space:
mode:
authorAsk Solem <ask@celeryproject.org>2013-06-25 11:03:50 +0100
committerAsk Solem <ask@celeryproject.org>2013-06-25 11:03:50 +0100
commit5c0b9774ff7ae6afccadef2038df2e6387eb325f (patch)
treef1a77ed43bbba2929a2d2608dda1319175dd1fac /kombu/transport/pyamqp.py
parent55d000019289be3ac9b38261a01cb57dcadbc432 (diff)
downloadkombu-5c0b9774ff7ae6afccadef2038df2e6387eb325f.tar.gz
cosmetics
Diffstat (limited to 'kombu/transport/pyamqp.py')
-rw-r--r--kombu/transport/pyamqp.py6
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()