diff options
| -rw-r--r-- | docs/userguide/producers.rst | 2 | ||||
| -rw-r--r-- | kombu/compat.py | 1 | ||||
| -rw-r--r-- | kombu/connection.py | 2 | ||||
| -rw-r--r-- | kombu/simple.py | 1 | ||||
| -rw-r--r-- | kombu/utils/functional.py | 1 |
5 files changed, 2 insertions, 5 deletions
diff --git a/docs/userguide/producers.rst b/docs/userguide/producers.rst index fc517cbf..4fce77b5 100644 --- a/docs/userguide/producers.rst +++ b/docs/userguide/producers.rst @@ -35,7 +35,7 @@ Having a producer instance you can publish messages: ... {'hello': 'world'}, # message to send ... exchange=exchange, # destination exchange ... routing_key='rk', # destination routing key, - ... decare=[exchange], # make sure exchange is declared, + ... declare=[exchange], # make sure exchange is declared, ... ) diff --git a/kombu/compat.py b/kombu/compat.py index 705e16bf..3871ea7c 100644 --- a/kombu/compat.py +++ b/kombu/compat.py @@ -85,7 +85,6 @@ class Consumer(messaging.Consumer): durable = True exclusive = False auto_delete = False - exchange_type = 'direct' _closed = False def __init__(self, connection, queue=None, exchange=None, diff --git a/kombu/connection.py b/kombu/connection.py index 1f5dba7b..178213c9 100644 --- a/kombu/connection.py +++ b/kombu/connection.py @@ -173,7 +173,7 @@ class Connection(object): # e.g. sqla+mysql://root:masterkey@localhost/ params['transport'], params['hostname'] = \ hostname.split('+', 1) - transport = self.uri_prefix = params['transport'] + self.uri_prefix = params['transport'] else: transport = transport or urlparse(hostname).scheme if not get_transport_cls(transport).can_parse_url: diff --git a/kombu/simple.py b/kombu/simple.py index eb0d82eb..29bf7474 100644 --- a/kombu/simple.py +++ b/kombu/simple.py @@ -128,7 +128,6 @@ class SimpleQueue(SimpleBase): queue = entity.Queue(name, exchange, name, **queue_opts) routing_key = name else: - name = queue.name exchange = queue.exchange routing_key = queue.routing_key consumer = messaging.Consumer(channel, queue) diff --git a/kombu/utils/functional.py b/kombu/utils/functional.py index 90b5ddf3..750d5dba 100644 --- a/kombu/utils/functional.py +++ b/kombu/utils/functional.py @@ -324,7 +324,6 @@ def retry_over_time(fun, catch, args=[], kwargs={}, errback=None, interval_max (float): Maximum number of seconds to sleep between retries. """ - retries = 0 interval_range = fxrange(interval_start, interval_max + interval_start, interval_step, repeatlast=True) |