We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6eb69d6 commit 7be0a95Copy full SHA for 7be0a95
tests/test_publisher.py
@@ -476,11 +476,11 @@ def test_durable_message(connection: Connection) -> None:
476
consumer = connection.consumer(destination)
477
should_be_durable = consumer.consume()
478
assert should_be_durable.durable is True
479
+ consumer.close()
480
# it does not work due of https://github.com/rabbitmq/rabbitmq-amqp-python-client/issues/83
481
# should_be_not_durable = consumer.consume()
482
# assert should_be_not_durable.durable is False
483
# message_count = management.purge_queue(queue_name)
484
management.purge_queue(queue_name)
485
# assert message_count == 0
486
management.delete_queue(queue_name)
- consumer.close()
0 commit comments