diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2011-02-17 15:09:11 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2011-02-17 15:09:11 +0000 |
| commit | 6e9b81e7f36ad540279debba2b13fd8bf56cccd1 (patch) | |
| tree | c160d421039a19aba2fde639c75e3e50ee131153 /src | |
| parent | dfd0364f817f260ac5f8b72afff853c149441cb0 (diff) | |
| download | rabbitmq-server-git-6e9b81e7f36ad540279debba2b13fd8bf56cccd1.tar.gz | |
cosmetic
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_channel.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 2c8f1a33d3..4fd7e7e4e3 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -505,9 +505,9 @@ process_confirms(MsgSeqNos, QPid, State = #ch{unconfirmed_mq = UMQ, lists:foldl( fun(MsgSeqNo, {_DMs, UMQ0, _UQM} = Acc) -> case gb_trees:lookup(MsgSeqNo, UMQ0) of - none -> Acc; {value, XQ} -> remove_unconfirmed(MsgSeqNo, QPid, XQ, Acc, - State) + State); + none -> Acc end end, {[], UMQ, UQM}, MsgSeqNos), {MXs, State#ch{unconfirmed_mq = UMQ1, unconfirmed_qm = UQM1}}. |