Make output queues exclusive and auto deleteable.
This way they are deleted after no one is consuming from them anymore.
@@ -95,4 +95,6 @@ STREAM_LIVEACTION_WORK_QUEUE = Queue(None, liveaction.LIVEACTION_XCHG,
# TODO: Perhaps we should use pack.action name as routing key so we can do more efficient filtering
# later, if needed
STREAM_EXECUTION_OUTPUT_QUEUE = execution.get_output_queue(name=None,
- routing_key=publishers.CREATE_RK)
+ routing_key=publishers.CREATE_RKm
+ exclusive=True
+ auto_delete=True)
