diff options
| author | Ask Solem <ask@celeryproject.org> | 2012-06-15 19:32:40 +0200 |
|---|---|---|
| committer | Ask Solem <ask@celeryproject.org> | 2012-06-15 19:32:40 +0200 |
| commit | 5e7a32440f803321a58453efb3ea0fde0d4497b2 (patch) | |
| tree | 3fe4f3e58b85b18105141d799779f30d043ecd82 /kombu/compat.py | |
| parent | 8d5652600e9afc76c803958638821a12018b8803 (diff) | |
| download | kombu-5e7a32440f803321a58453efb3ea0fde0d4497b2.tar.gz | |
Use single quotes
Diffstat (limited to 'kombu/compat.py')
| -rw-r--r-- | kombu/compat.py | 22 |
1 files changed, 11 insertions, 11 deletions
diff --git a/kombu/compat.py b/kombu/compat.py index 96fa026a..88874aad 100644 --- a/kombu/compat.py +++ b/kombu/compat.py @@ -17,7 +17,7 @@ from itertools import count from . import messaging from .entity import Exchange, Queue -__all__ = ["Publisher", "Consumer"] +__all__ = ['Publisher', 'Consumer'] def _iterconsume(connection, consumer, no_ack=False, limit=None): @@ -29,9 +29,9 @@ def _iterconsume(connection, consumer, no_ack=False, limit=None): class Publisher(messaging.Producer): - exchange = "" - exchange_type = "direct" - routing_key = "" + exchange = '' + exchange_type = 'direct' + routing_key = '' durable = True auto_delete = False _closed = False @@ -78,14 +78,14 @@ class Publisher(messaging.Producer): class Consumer(messaging.Consumer): - queue = "" - exchange = "" - routing_key = "" - exchange_type = "direct" + queue = '' + exchange = '' + routing_key = '' + exchange_type = 'direct' durable = True exclusive = False auto_delete = False - exchange_type = "direct" + exchange_type = 'direct' _closed = False def __init__(self, connection, queue=None, exchange=None, @@ -146,12 +146,12 @@ class Consumer(messaging.Consumer): return message def process_next(self): - raise NotImplementedError("Use fetch(enable_callbacks=True)") + raise NotImplementedError('Use fetch(enable_callbacks=True)') def discard_all(self, filterfunc=None): if filterfunc is not None: raise NotImplementedError( - "discard_all does not implement filters") + 'discard_all does not implement filters') return self.purge() def iterconsume(self, limit=None, no_ack=None): |