@@ -2178,12 +2178,7 @@ deliver_to_queues({Delivery = #delivery{message = Message = #basic_message{ex
2178
2178
rabbit_global_counters :messages_routed (amqp091 , erlang :min (1 , length (Qs ))),
2179
2179
% % NB: the order here is important since basic.returns must be
2180
2180
% % sent before confirms.
2181
- <<<<<<< HEAD
2182
- ok = process_routing_mandatory (Mandatory , Qs , Message , State0 ),
2183
- =======
2184
2181
ok = process_routing_mandatory (ExtendedReturnCallback , Mandatory , Qs , MsgSeqNo , Message , State0 ),
2185
- QueueNames = rabbit_amqqueue :queue_names (Qs ),
2186
- >>>>>>> d8f77c5882 (Settle unroutable message with released state )
2187
2182
State1 = process_routing_confirm (Confirm , QueueNames , MsgSeqNo , XName , State0 ),
2188
2183
% % Actions must be processed after registering confirms as actions may
2189
2184
% % contain rejections of publishes
@@ -2222,12 +2217,7 @@ deliver_to_queues({Delivery = #delivery{message = Message = #basic_message{ex
2222
2217
rabbit_global_counters :messages_routed (amqp091 , length (Qs )),
2223
2218
% % NB: the order here is important since basic.returns must be
2224
2219
% % sent before confirms.
2225
- <<<<<<< HEAD
2226
- ok = process_routing_mandatory (Mandatory , Qs , Message , State0 ),
2227
- =======
2228
2220
ok = process_routing_mandatory (ExtendedReturnCallback , Mandatory , Qs , MsgSeqNo , Message , State0 ),
2229
- QueueNames = rabbit_amqqueue :queue_names (Qs ),
2230
- >>>>>>> d8f77c5882 (Settle unroutable message with released state )
2231
2221
State1 = process_routing_confirm (Confirm , QueueNames ,
2232
2222
MsgSeqNo , XName , State0 ),
2233
2223
% % Actions must be processed after registering confirms as actions may
0 commit comments