get rid of exclusive
@@ -56,7 +56,7 @@ class Rabbit_Base(object): # pragma: no cover
rabbit_channel = rabbit_connection.channel()
rabbit_channel.exchange_declare(exchange=exchange,
exchange_type='topic')
- rabbit_channel.queue_declare(queue=queue_name, exclusive=True)
+ rabbit_channel.queue_declare(queue=queue_name, exclusive=False)
self.logger.debug('connected to {0} rabbitmq...'.format(host))
wait = False
except Exception as e:
