remove unneeded connection= in carrot Consumer init
This commit is contained in:
@@ -171,7 +171,6 @@ class Consumer(messaging.Consumer):
|
|||||||
"""
|
"""
|
||||||
|
|
||||||
def __init__(self, *args, **kwargs):
|
def __init__(self, *args, **kwargs):
|
||||||
connection = kwargs.get('connection')
|
|
||||||
max_retries = FLAGS.rabbit_max_retries
|
max_retries = FLAGS.rabbit_max_retries
|
||||||
sleep_time = FLAGS.rabbit_retry_interval
|
sleep_time = FLAGS.rabbit_retry_interval
|
||||||
tries = 0
|
tries = 0
|
||||||
|
|||||||
Reference in New Issue
Block a user