diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-01-13 01:25:59 +0000 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-01-13 01:25:59 +0000 |
| commit | 65a5ba3b58a04c80ec0d212dc9a506574bf4f64a (patch) | |
| tree | 781dde49874e4c616ea83aa864c7a1de92fba666 | |
| parent | 3bd08a3f8f02048e2fa0d1d7da09393d7d624305 (diff) | |
| download | rabbitmq-server-65a5ba3b58a04c80ec0d212dc9a506574bf4f64a.tar.gz | |
inline a function
| -rw-r--r-- | src/rabbit_channel.erl | 14 |
1 files changed, 3 insertions, 11 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index f4122e95..1b998f31 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -475,14 +475,6 @@ confirm([], _QPid, State) -> State; confirm(_MsgSeqNos, _QPid, State = #ch{confirm_enabled = false}) -> State; -confirm(MsgSeqNos, undefined, State) -> - %% This case is for confirms originating in the channel: it is - %% only triggered by unroutable messages marked mandatory or - %% immediate or messages routed to zero queues. In this case, 1) - %% the unconfirmed set does not contain the message, and 2) the - %% message was not delivered to any queues, so queues_for_msg will - %% not have any relevant entries. - send_confirms(MsgSeqNos, State); confirm(MsgSeqNos, QPid, State) -> {DoneMessages, State1} = lists:foldl( @@ -1217,12 +1209,12 @@ is_message_persistent(Content) -> process_routing_result(unroutable, _, MsgSeqNo, Message, State) -> ok = basic_return(Message, State#ch.writer_pid, no_route), - confirm([MsgSeqNo], undefined, State); + send_confirms([MsgSeqNo], State); process_routing_result(not_delivered, _, MsgSeqNo, Message, State) -> ok = basic_return(Message, State#ch.writer_pid, no_consumers), - confirm([MsgSeqNo], undefined, State); + send_confirms([MsgSeqNo], State); process_routing_result(routed, [], MsgSeqNo, _, State) -> - confirm([MsgSeqNo], undefined, State); + send_confirms([MsgSeqNo], State); process_routing_result(routed, _, undefined, _, State) -> State; process_routing_result(routed, QPids, MsgSeqNo, _, |