@@ -286,7 +286,7 @@ start_cluster(Q) ->
286286 ? RPC_TIMEOUT )],
287287 MinVersion = lists :min ([rabbit_fifo :version () | Versions ]),
288288
289- ? LOG_DEBUG (" Will start up to ~w replicas for quorum queue ~ts with "
289+ ? LOG_DEBUG (" Will start up to ~w replicas for quorum ~ts with "
290290 " leader on node '~ts ', initial machine version ~b " ,
291291 [QuorumSize , rabbit_misc :rs (QName ), LeaderNode , MinVersion ]),
292292 case rabbit_amqqueue :internal_declare (NewQ1 , false ) of
@@ -663,7 +663,7 @@ handle_tick(QName,
663663 ok ->
664664 ok ;
665665 repaired ->
666- ? LOG_DEBUG (" Repaired quorum queue ~ts amqqueue record" ,
666+ ? LOG_DEBUG (" Repaired quorum ~ts amqqueue record" ,
667667 [rabbit_misc :rs (QName )])
668668 end ,
669669 ExpectedNodes = rabbit_nodes :list_members (),
@@ -1376,7 +1376,7 @@ add_member(VHost, Name, Node, Membership, Timeout)
13761376 is_binary (Name ) andalso
13771377 is_atom (Node ) ->
13781378 QName = # resource {virtual_host = VHost , name = Name , kind = queue },
1379- ? LOG_DEBUG (" Asked to add a replica for queue ~ts on node ~ts " ,
1379+ ? LOG_DEBUG (" Asked to add a replica for ~ts on node ~ts " ,
13801380 [rabbit_misc :rs (QName ), Node ]),
13811381 case rabbit_amqqueue :lookup (QName ) of
13821382 {ok , Q } when ? amqqueue_is_classic (Q ) ->
@@ -2178,7 +2178,7 @@ force_all_queues_shrink_member_to_current_member(ListQQFun) when is_function(Lis
21782178 QName = amqqueue :get_name (Q ),
21792179 {RaName , _ } = amqqueue :get_pid (Q ),
21802180 OtherNodes = lists :delete (Node , get_nodes (Q )),
2181- ? LOG_WARNING (" Shrinking queue ~ts to a single node: ~ts " , [rabbit_misc :rs (QName ), Node ]),
2181+ ? LOG_WARNING (" Shrinking ~ts to a single node: ~ts " , [rabbit_misc :rs (QName ), Node ]),
21822182 ok = ra_server_proc :force_shrink_members_to_current_member ({RaName , Node }),
21832183 Fun = fun (QQ ) ->
21842184 TS0 = amqqueue :get_type_state (QQ ),
0 commit comments