@@ -505,6 +505,7 @@ def await_event_propagation
505505 it "deletes a queue" do
506506 q = @channel . queue ( queue_name , durable : false )
507507 subject . delete_queue ( "/" , queue_name )
508+ expect { subject . queue_info ( "/" , queue_name ) } . to raise_error ( Faraday ::ResourceNotFound )
508509 end
509510
510511 it "doesn't delete non-empty queue if if-empty is set" do
@@ -516,21 +517,20 @@ def await_event_propagation
516517
517518 subject . purge_queue ( "/" , q . name )
518519 subject . delete_queue ( "/" , queue_name , false , true )
520+ expect { subject . queue_info ( "/" , queue_name ) } . to raise_error ( Faraday ::ResourceNotFound )
519521 end
520522
521523 it "doesn't delete used queue if if-unused is set" do
522524 q = @channel . queue ( queue_name , durable : false )
523- # Simulate the queue being used by creating a consumer
524- consumer = q . subscribe do |_delivery_info , _properties , _body |
525- # consumer block
526- end
525+ consumer = q . subscribe
527526
528527 expect do
529528 subject . delete_queue ( "/" , queue_name , true , false )
530529 end . to raise_error ( Faraday ::ClientError )
531530
532531 consumer . cancel
533- subject . delete_queue ( "/" , queue_name , false , true )
532+ subject . delete_queue ( "/" , queue_name , true , false )
533+ expect { subject . queue_info ( "/" , queue_name ) } . to raise_error ( Faraday ::ResourceNotFound )
534534 end
535535 end
536536
0 commit comments