From 15cf24b7daf4803c0591adb0e54167ad348c3d22 Mon Sep 17 00:00:00 2001 From: Roy Moore Date: Fri, 5 Jun 2026 01:10:16 +0300 Subject: [PATCH] test(rabbitmq): declare exchange and queue as durable --- modules/rabbitmq/tests/test_rabbitmq.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/modules/rabbitmq/tests/test_rabbitmq.py b/modules/rabbitmq/tests/test_rabbitmq.py index c0c1894d8..ae6f442b3 100644 --- a/modules/rabbitmq/tests/test_rabbitmq.py +++ b/modules/rabbitmq/tests/test_rabbitmq.py @@ -43,8 +43,8 @@ def test_docker_run_rabbitmq( # create exchange and queue: channel = connection.channel() - channel.exchange_declare(exchange=EXCHANGE, exchange_type="topic") - channel.queue_declare(QUEUE, arguments={}) + channel.exchange_declare(exchange=EXCHANGE, exchange_type="topic", durable=True) + channel.queue_declare(QUEUE, durable=True, arguments={}) channel.queue_bind(QUEUE, EXCHANGE, ROUTING_KEY) # publish message: