@@ -2208,12 +2208,7 @@ deliver_to_queues({Delivery = #delivery{message = Message = #basic_message{ex
2208
2208
rabbit_global_counters :messages_routed (amqp091 , erlang :min (1 , length (Qs ))),
2209
2209
% % NB: the order here is important since basic.returns must be
2210
2210
% % sent before confirms.
2211
- <<<<<<< HEAD
2212
- ok = process_routing_mandatory (Mandatory , Qs , Message , State0 ),
2213
- =======
2214
2211
ok = process_routing_mandatory (ExtendedReturnCallback , Mandatory , Qs , MsgSeqNo , Message , State0 ),
2215
- QueueNames = rabbit_amqqueue :queue_names (Qs ),
2216
- >>>>>>> d8f77c5882 (Settle unroutable message with released state )
2217
2212
State1 = process_routing_confirm (Confirm , QueueNames , MsgSeqNo , XName , State0 ),
2218
2213
% % Actions must be processed after registering confirms as actions may
2219
2214
% % contain rejections of publishes
@@ -2257,12 +2252,7 @@ deliver_to_queues({Delivery = #delivery{message = Message = #basic_message{ex
2257
2252
rabbit_global_counters :messages_routed (amqp091 , length (Qs )),
2258
2253
% % NB: the order here is important since basic.returns must be
2259
2254
% % sent before confirms.
2260
- <<<<<<< HEAD
2261
- ok = process_routing_mandatory (Mandatory , Qs , Message , State0 ),
2262
- =======
2263
2255
ok = process_routing_mandatory (ExtendedReturnCallback , Mandatory , Qs , MsgSeqNo , Message , State0 ),
2264
- QueueNames = rabbit_amqqueue :queue_names (Qs ),
2265
- >>>>>>> d8f77c5882 (Settle unroutable message with released state )
2266
2256
State1 = process_routing_confirm (Confirm , QueueNames ,
2267
2257
MsgSeqNo , XName , State0 ),
2268
2258
% % Actions must be processed after registering confirms as actions may
0 commit comments