@@ -270,27 +270,15 @@ transfer_leadership_of_classic_mirrored_queues(TransferCandidates) ->
270
270
[rabbit_misc :rs (Name ), readable_candidate_list (ExistingReplicaNodes )]),
271
271
case random_primary_replica_transfer_candidate_node (TransferCandidates , ExistingReplicaNodes ) of
272
272
{ok , Pick } ->
273
- <<<<<<< HEAD
274
- _ = rabbit_log :debug (" Will transfer leadership of local ~s to node ~s " ,
275
- [rabbit_misc :rs (Name ), Pick ]),
276
- case rabbit_mirror_queue_misc :migrate_leadership_to_existing_replica (Q , Pick ) of
277
- {migrated , _ } ->
278
- _ = rabbit_log :debug (" Successfully transferred leadership of queue ~s to node ~s " ,
279
- [rabbit_misc :rs (Name ), Pick ]);
280
- Other ->
281
- _ = rabbit_log :warning (" Could not transfer leadership of queue ~s to node ~s : ~p " ,
282
- [rabbit_misc :rs (Name ), Pick , Other ])
283
- =======
284
- rabbit_log :debug (" Will transfer leadership of local ~s . Planned target node: ~s " ,
285
- [rabbit_misc :rs (Name ), Pick ]),
273
+ _ = rabbit_log :debug (" Will transfer leadership of local ~s . Planned target node: ~s " ,
274
+ [rabbit_misc :rs (Name ), Pick ]),
286
275
case rabbit_mirror_queue_misc :migrate_leadership_to_existing_replica (Q , Pick ) of
287
276
{migrated , NewPrimary } ->
288
- rabbit_log :debug (" Successfully transferred leadership of queue ~s to node ~s " ,
289
- [rabbit_misc :rs (Name ), NewPrimary ]);
277
+ _ = rabbit_log :debug (" Successfully transferred leadership of queue ~s to node ~s " ,
278
+ [rabbit_misc :rs (Name ), NewPrimary ]);
290
279
Other ->
291
- rabbit_log :warning (" Could not transfer leadership of queue ~s : ~p " ,
292
- [rabbit_misc :rs (Name ), Other ])
293
- >>>>>>> 5 f71db9197 (Fix migrate leadership timeout )
280
+ _ = rabbit_log :warning (" Could not transfer leadership of queue ~s : ~p " ,
281
+ [rabbit_misc :rs (Name ), Other ])
294
282
end ;
295
283
undefined ->
296
284
_ = rabbit_log :warning (" Could not transfer leadership of queue ~s : no suitable candidates?" ,
0 commit comments