Skip to content

Commit 2566c73

Browse files
committed
Fix conflict
1 parent 90d6b7a commit 2566c73

File tree

1 file changed

+4
-14
lines changed

1 file changed

+4
-14
lines changed

deps/rabbit/src/rabbit_channel.erl

Lines changed: 4 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -2192,15 +2192,10 @@ deliver_to_queues({Delivery = #delivery{message = Message = #basic_message{ex
21922192
mandatory = Mandatory,
21932193
confirm = Confirm,
21942194
msg_seq_no = MsgSeqNo},
2195-
<<<<<<< HEAD
2196-
RoutedToQueueNames = [QName]}, State0 = #ch{queue_states = QueueStates0}) -> %% optimisation when there is one queue
2195+
RoutedToQueueNames = [QName]},
2196+
State0 = #ch{cfg = #conf{extended_return_callback = ExtendedReturnCallback},
2197+
queue_states = QueueStates0}) -> %% optimisation when there is one queue
21972198
Qs0 = rabbit_amqqueue:lookup(RoutedToQueueNames),
2198-
=======
2199-
RoutedToQueueNames = [QName]},
2200-
State0 = #ch{cfg = #conf{extended_return_callback = ExtendedReturnCallback},
2201-
queue_states = QueueStates0}) -> %% optimisation when there is one queue
2202-
Qs0 = rabbit_amqqueue:lookup_many(RoutedToQueueNames),
2203-
>>>>>>> 4c99c49587 (Settle unroutable message with released state)
22042199
Qs = rabbit_amqqueue:prepend_extra_bcc(Qs0),
22052200
QueueNames = lists:map(fun amqqueue:get_name/1, Qs),
22062201
case rabbit_queue_type:deliver(Qs, Delivery, QueueStates0) of
@@ -2236,15 +2231,10 @@ deliver_to_queues({Delivery = #delivery{message = Message = #basic_message{ex
22362231
mandatory = Mandatory,
22372232
confirm = Confirm,
22382233
msg_seq_no = MsgSeqNo},
2239-
<<<<<<< HEAD
2240-
RoutedToQueueNames}, State0 = #ch{queue_states = QueueStates0}) ->
2241-
Qs0 = rabbit_amqqueue:lookup(RoutedToQueueNames),
2242-
=======
22432234
RoutedToQueueNames},
22442235
State0 = #ch{cfg = #conf{extended_return_callback = ExtendedReturnCallback},
22452236
queue_states = QueueStates0}) ->
2246-
Qs0 = rabbit_amqqueue:lookup_many(RoutedToQueueNames),
2247-
>>>>>>> 4c99c49587 (Settle unroutable message with released state)
2237+
Qs0 = rabbit_amqqueue:lookup(RoutedToQueueNames),
22482238
Qs = rabbit_amqqueue:prepend_extra_bcc(Qs0),
22492239
QueueNames = lists:map(fun amqqueue:get_name/1, Qs),
22502240
case rabbit_queue_type:deliver(Qs, Delivery, QueueStates0) of

0 commit comments

Comments
 (0)