diff options
| author | Emile Joubert <emile@rabbitmq.com> | 2011-12-01 17:05:15 +0000 |
|---|---|---|
| committer | Emile Joubert <emile@rabbitmq.com> | 2011-12-01 17:05:15 +0000 |
| commit | ae1bb4d6ab5644b87fd37a89356157449c34dbfe (patch) | |
| tree | 645d34f200da7528f90afde29a09b85d3a976e5b | |
| parent | 5acd6a1d77673ac6270bdf8d02e9fcc51c193d1f (diff) | |
| download | rabbitmq-server-git-ae1bb4d6ab5644b87fd37a89356157449c34dbfe.tar.gz | |
Minor ecumenical matter
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index 393bd2da81..d68063db80 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -527,9 +527,9 @@ promote_me(From, #state { q = Q = #amqqueue { name = QName }, CPid, BQ, BQS, GM, SS, MonitoringPids), MTC = lists:foldl(fun ({MsgId, {published, ChPid, MsgSeqNo}}, MTC0) -> - gb_trees:insert(MsgId, {ChPid, MsgSeqNo}, MTC0); + gb_trees:insert(MsgId, {ChPid, MsgSeqNo}, MTC0); (_, MTC0) -> - MTC0 + MTC0 end, gb_trees:empty(), MSList), NumAckTags = [NumAckTag || {_MsgId, NumAckTag} <- dict:to_list(MA)], AckTags = [AckTag || {_Num, AckTag} <- lists:sort(NumAckTags)], |