From 823f46cd276b718d01b52f5275f1953c27523ca3 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Ceyda=20Din=C3=A7er?= Date: Sun, 21 Jun 2026 14:51:11 +0000 Subject: [PATCH] Fix deprecated queue declarations for RabbitMQ 4.3.x MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Ceyda Dinçer --- villas/controller/commands/monitor.py | 3 ++- villas/controller/commands/simulator.py | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) 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)