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 | 3faadc7dfdb6207ee97e29a2e430eb75074797f9 (patch) | |
| tree | fec3f759b6cba482171b060725b8b2bdaad30bf8 | |
| parent | 25218fe465274d0f40800c118daab2a6d5ab40d6 (diff) | |
| download | rabbitmq-server-3faadc7dfdb6207ee97e29a2e430eb75074797f9.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 abd30a26..36b8885f 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}} -> |