Commit 388e6bb9 authored by Federico Sismondi's avatar Federico Sismondi
Browse files

queues are declared as auto delete, so when agents go offline queues are deleted

parent a1b50b4d
......@@ -59,14 +59,16 @@ class BaseConsumer(ConsumerMixin):
routing_key='control.{consumer_name}.toAgent.{name}'.format(
consumer_name=consumer_name,
name=name),
durable=False)
durable=False,
auto_delete=True)
self.data_queue = Queue("data.{consumer_name}@{name}".format(name=name,
consumer_name=consumer_name),
exchange=self.exchange,
routing_key='data.{consumer_name}.toAgent.{name}'.format(consumer_name=consumer_name,
name=name),
durable=False)
durable=False,
auto_delete=True)
def get_consumers(self, Consumer, channel):
return [
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment