diff --git a/villas/controller/commands/monitor.py b/villas/controller/commands/monitor.py index 9833697..fdb6782 100644 --- a/villas/controller/commands/monitor.py +++ b/villas/controller/commands/monitor.py @@ -32,7 +32,8 @@ def run(connection, args): queue = kombu.Queue(exchange=exchange, binding_arguments=headers, - durable=False) + durable=False, + exclusive=True) consumer = kombu.Consumer(connection, queues=queue, diff --git a/villas/controller/commands/simulator.py b/villas/controller/commands/simulator.py index f83b3d8..ec1bf71 100644 --- a/villas/controller/commands/simulator.py +++ b/villas/controller/commands/simulator.py @@ -104,7 +104,8 @@ def run(connection, args): consumer = kombu.Consumer(channel, queues=kombu.Queue( exchange=exchange, - durable=False + durable=False, + exclusive=True ), on_message=SimulatorPingCommand.on_message)