File tree Expand file tree Collapse file tree 2 files changed +8
-11
lines changed
rabbitmq_amqp_python_client Expand file tree Collapse file tree 2 files changed +8
-11
lines changed Original file line number Diff line number Diff line change @@ -138,6 +138,7 @@ def _request(
138138 reply_to = "$me" ,
139139 address = path ,
140140 subject = method ,
141+ durable = False ,
141142 )
142143
143144 if self ._sender is not None :
Original file line number Diff line number Diff line change @@ -474,16 +474,12 @@ def test_durable_message(connection: Connection) -> None:
474474 assert status .remote_state == OutcomeState .ACCEPTED
475475
476476 consumer = connection .consumer (destination )
477- # should_be_durable = consumer.consume()
478- # assert should_be_durable.durable is True
479-
480- # should_be_not_durable = consumer.consume()
481- # assert should_be_not_durable.durable is False
482-
483- consumer .close ()
477+ should_be_durable = consumer .consume ()
478+ assert should_be_durable .durable is True
484479
480+ should_be_not_durable = consumer .consume ()
481+ assert should_be_not_durable .durable is False
482+ message_count = management .purge_queue (queue_name )
483+ assert message_count == 0
485484 management .delete_queue (queue_name )
486-
487- management .close ()
488-
489- pass
485+ consumer .close ()
You can’t perform that action at this time.
0 commit comments