File tree Expand file tree Collapse file tree 1 file changed +5
-4
lines changed Expand file tree Collapse file tree 1 file changed +5
-4
lines changed Original file line number Diff line number Diff line change @@ -466,9 +466,9 @@ def test_durable_message(connection: Connection) -> None:
466466 # message should be not durable by setting the durable to False by the user
467467
468468 m = Message (
469- body = Converter .string_to_bytes ("not durable" ),
470- durable = False ,
471- )
469+ body = Converter .string_to_bytes ("not durable" ),
470+ durable = False ,
471+ )
472472 status = publisher .publish (m )
473473
474474 assert status .remote_state == OutcomeState .ACCEPTED
@@ -479,7 +479,8 @@ def test_durable_message(connection: Connection) -> None:
479479 # it does not work due of https://github.com/rabbitmq/rabbitmq-amqp-python-client/issues/83
480480 # should_be_not_durable = consumer.consume()
481481 # assert should_be_not_durable.durable is False
482- message_count = management .purge_queue (queue_name )
482+ # message_count = management.purge_queue(queue_name)
483+ management .purge_queue (queue_name )
483484 # assert message_count == 0
484485 management .delete_queue (queue_name )
485486 consumer .close ()
You can’t perform that action at this time.
0 commit comments