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(
138
138
reply_to = "$me" ,
139
139
address = path ,
140
140
subject = method ,
141
+ durable = False ,
141
142
)
142
143
143
144
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:
474
474
assert status .remote_state == OutcomeState .ACCEPTED
475
475
476
476
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
484
479
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
485
484
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