@@ -531,14 +531,14 @@ with_or_die(Name, F) ->
531
531
({absent , Q , Reason }) -> rabbit_misc :absent (Q , Reason )
532
532
end ).
533
533
534
- assert_equivalence (Q , DurableDeclare , AutoDeleteDeclare , Args1 , Owner ) ->
535
- QName = amqqueue : get_name ( Q ) ,
536
- DurableQ = amqqueue : is_durable ( Q ) ,
537
- AutoDeleteQ = amqqueue : is_auto_delete ( Q ),
538
- ok = check_exclusive_access ( Q , Owner , strict ),
539
- ok = rabbit_misc :assert_field_equivalence (DurableQ , DurableDeclare , QName , durable ),
540
- ok = rabbit_misc : assert_field_equivalence ( AutoDeleteQ , AutoDeleteDeclare , QName , auto_delete ),
541
- ok = assert_args_equivalence (Q , Args1 ).
534
+ assert_equivalence (# amqqueue { name = QName ,
535
+ durable = Durable ,
536
+ auto_delete = AD } = Q ,
537
+ Durable1 , AD1 , Args1 , Owner ) ->
538
+ rabbit_misc : assert_field_equivalence ( Durable , Durable1 , QName , durable ),
539
+ rabbit_misc :assert_field_equivalence (AD , AD1 , QName , auto_delete ),
540
+ assert_args_equivalence ( Q , Args1 ),
541
+ check_exclusive_access (Q , Owner , strict ).
542
542
543
543
check_exclusive_access (Q , Owner ) -> check_exclusive_access (Q , Owner , lax ).
544
544
@@ -549,9 +549,7 @@ check_exclusive_access(#amqqueue{exclusive_owner = none}, _ReaderPid, lax) ->
549
549
check_exclusive_access (# amqqueue {name = QueueName }, _ReaderPid , _MatchType ) ->
550
550
rabbit_misc :protocol_error (
551
551
resource_locked ,
552
- " cannot obtain exclusive access to locked ~s . It could be originally "
553
- " declared on another connection or the exclusive property value does not "
554
- " match that of the original declaration." ,
552
+ " cannot obtain exclusive access to locked ~s " ,
555
553
[rabbit_misc :rs (QueueName )]).
556
554
557
555
with_exclusive_access_or_die (Name , ReaderPid , F ) ->
0 commit comments