diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2019-05-13 05:24:46 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2019-05-13 05:24:46 +0300 |
| commit | 5fc52bbda986b384d22049ead337d6f2da05815d (patch) | |
| tree | b6b7c8c21e68e46b32ecd780bc8055d2873ed86e | |
| parent | d70f04bd27b43cc6471be7d7bcebb92a62c6f721 (diff) | |
| download | rabbitmq-server-git-5fc52bbda986b384d22049ead337d6f2da05815d.tar.gz | |
Cosmetics
| -rw-r--r-- | src/rabbit_channel.erl | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index ddd36eb4ec..1b9102375d 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -707,7 +707,7 @@ handle_cast({mandatory_received, _MsgSeqNo}, State) -> handle_cast({reject_publish, MsgSeqNo, _QPid}, State = #ch{unconfirmed = UC}) -> %% It does not matter which queue rejected the message, - %% if any queue rejected it - it should not be confirmed. + %% if any queue did, it should not be confirmed. {MaybeRejected, UC1} = unconfirmed_messages:reject_msg(MsgSeqNo, UC), %% NB: don't call noreply/1 since we don't want to send confirms. case MaybeRejected of @@ -774,7 +774,7 @@ handle_info({ra_event, {Name, _} = From, _} = Evt, {ConfirmMXs, RejectMXs, UC1} = unconfirmed_messages:forget_ref(Name, State2#ch.unconfirmed), %% Deleted queue is a special case. - %% Do not nack rejected messages. + %% Do not nack the "rejected" messages. State3 = record_confirms(ConfirmMXs ++ RejectMXs, State2#ch{unconfirmed = UC1}), erase_queue_stats(QName), @@ -784,7 +784,7 @@ handle_info({ra_event, {Name, _} = From, _} = Evt, end; _ -> %% the assumption here is that the queue state has been cleaned up and - %% this is a residual ra notification + %% this is a residual Ra notification noreply_coalesce(State0) end; @@ -1843,7 +1843,7 @@ handle_publishing_queue_down(QPid, Reason, {ConfirmMXs, RejectMXs, UC1} = unconfirmed_messages:forget_ref(QPid, UC), %% Deleted queue is a special case. - %% Do not nack rejected messages. + %% Do not nack the "rejected" messages. record_confirms(ConfirmMXs ++ RejectMXs, State#ch{unconfirmed = UC1}); {false, _} -> |