Skip to content

Commit 9a15c76

Browse files
committed
clarifies sentence
1 parent 5be0f64 commit 9a15c76

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

src/rabbit_amqqueue_process.erl

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -670,11 +670,11 @@ handle_ch_down(DownPid, State = #q{consumers = Consumers,
670670
%% with regards to the credit we were tracking for the channel
671671
%% process. See handle_cast({deliver, Deliver}, State) in this
672672
%% module. In that cast function we process deliveries from the
673-
%% channel, which means whe credit_flow:ack/1 said messages, so we
674-
%% were keeping track of when this rabbit_amqqueue_process would
675-
%% grant more credits to the rabbit_channel process. Since the
676-
%% process died, the credit_flow flow module will clean up that
677-
%% for us.
673+
%% channel, which means we credit_flow:ack/1 said
674+
%% messages. credit_flow:ack'ing messages means we are increasing
675+
%% a counter to know when we need to send MoreCreditAfter. Since
676+
%% the process died, the credit_flow flow module will clean up
677+
%% that for us.
678678
credit_flow:peer_down(DownPid),
679679
pmon:demonitor(DownPid, Senders)
680680
end},

0 commit comments

Comments
 (0)