diff --git a/roles/basset/worker/files/basset-worker b/roles/basset/worker/files/basset-worker index 62e63d7236..57026f9e28 100644 --- a/roles/basset/worker/files/basset-worker +++ b/roles/basset/worker/files/basset-worker @@ -153,7 +153,8 @@ def callback(ch, method, properties, body): # Make sure we leave any other messages in the queue channel.basic_qos(prefetch_count=1) -channel.basic_consume(callback, queue='check_submission') +channel.basic_consume('check_submission', callback) +# queue='check_submission') try: log.debug('Starting consuming')