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: