summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAlvaro Videla <videlalvaro@gmail.com>2015-09-25 15:16:28 +0200
committerAlvaro Videla <videlalvaro@gmail.com>2015-09-25 15:16:28 +0200
commitb2a63a047c598fccd2fe020c7128e5344efbcec7 (patch)
tree6892c66c6e847ac7e9c5d3eb9365c402b414841e
parent9a15c76e3c8043a7d8416d2c8929724759f15392 (diff)
downloadrabbitmq-server-git-b2a63a047c598fccd2fe020c7128e5344efbcec7.tar.gz
typo
-rw-r--r--src/rabbit_channel.erl7
1 files changed, 3 insertions, 4 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl
index 692fca082c..b23a8410c5 100644
--- a/src/rabbit_channel.erl
+++ b/src/rabbit_channel.erl
@@ -465,10 +465,9 @@ handle_info({'DOWN', _MRef, process, QPid, Reason}, State) ->
State4 = handle_delivering_queue_down(QPid, State3),
%% A rabbit_amqqueue_process has died. If our channel was being
%% blocked by this process, and no other process is blocking our
- %% channel, then this channel will will be unblocked. This means
- %% that any credit that was deferred will be sent to the
- %% rabbit_reader processs that might be blocked by this particular
- %% channel.
+ %% channel, then this channel will be unblocked. This means that
+ %% any credit that was deferred will be sent to the rabbit_reader
+ %% processs that might be blocked by this particular channel.
credit_flow:peer_down(QPid),
#ch{queue_names = QNames, queue_monitors = QMons} = State4,
case dict:find(QPid, QNames) of