diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-01-10 09:36:52 +0000 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-01-10 09:36:52 +0000 |
| commit | ea5a64afed2143b6843359ce93a7c73b1f40dd54 (patch) | |
| tree | fec3f759b6cba482171b060725b8b2bdaad30bf8 | |
| parent | 2c601cdb6c7222d83ecd5054c2adcec8a81ad456 (diff) | |
| download | rabbitmq-server-git-ea5a64afed2143b6843359ce93a7c73b1f40dd54.tar.gz | |
misspelling
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index abd30a26e0..36b8885f58 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -426,12 +426,12 @@ deliver_from_queue_deliver(AckRequired, false, State) -> {{Message, IsDelivered, AckTag}, 0 == Remaining, State1}. confirm_messages(Guids, State) -> - {CMs, State1} = annote_confirms_with_channel(Guids, State), + {CMs, State1} = annotate_confirms_with_channel(Guids, State), CMs1 = group_confirms_by_channel(CMs), [rabbit_channel:confirm(ChPid, Msgs) || {ChPid, Msgs} <- CMs1], State1. -annote_confirms_with_channel(Guids, State) -> +annotate_confirms_with_channel(Guids, State) -> lists:foldl(fun(Guid, {CMs, State0 = #q{guid_to_channel = GTC0}}) -> case dict:find(Guid, GTC0) of {ok, {ChPid, MsgSeqNo}} -> |