diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2011-03-07 15:27:54 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2011-03-07 15:27:54 +0000 |
| commit | e5c6e403b66102b08a48ce12a13edeceecff46a4 (patch) | |
| tree | 167529138af8a482a3e7ea914d14abcfed25159b | |
| parent | f172b1a94b92dbb440a2889a61c1b714b0b40bdc (diff) | |
| download | rabbitmq-server-git-e5c6e403b66102b08a48ce12a13edeceecff46a4.tar.gz | |
guids be gone
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 215415414f..b32fa0ffe6 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -401,11 +401,11 @@ deliver_from_queue_deliver(AckRequired, false, State) -> confirm_messages(MsgIds, State = #q{msg_id_to_channel = MTC}) -> {CMs, MTC1} = lists:foldl( - fun(Guid, {CMs, MTC0}) -> - case dict:find(Guid, MTC0) of + fun(MsgId, {CMs, MTC0}) -> + case dict:find(MsgId, MTC0) of {ok, {ChPid, MsgSeqNo}} -> {gb_trees_cons(ChPid, MsgSeqNo, CMs), - dict:erase(Guid, MTC0)}; + dict:erase(MsgId, MTC0)}; _ -> {CMs, MTC0} end |