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 | 2219c3d554b1615a967acf62a288ac5813f2cb67 (patch) | |
| tree | 167529138af8a482a3e7ea914d14abcfed25159b | |
| parent | bdf1b2350d05b1d68ff7a9cb851c7e8835f4beec (diff) | |
| download | rabbitmq-server-2219c3d554b1615a967acf62a288ac5813f2cb67.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 21541541..b32fa0ff 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 |