diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2013-02-12 21:57:24 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2013-02-12 21:57:24 +0000 |
| commit | 77ad4b912377de31ace4afbc4bc3db96188d74c7 (patch) | |
| tree | b8b24c409696cd2c5bbd7e831b65539a651b1150 | |
| parent | 37dd46271a805a90b49d993d49ade8b70c47f1ef (diff) | |
| download | rabbitmq-server-bug25247.tar.gz | |
remove icky use of element/2bug25247
| -rw-r--r-- | src/rabbit_mirror_queue_misc.erl | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/src/rabbit_mirror_queue_misc.erl b/src/rabbit_mirror_queue_misc.erl index cc2d7c77..5cba2d43 100644 --- a/src/rabbit_mirror_queue_misc.erl +++ b/src/rabbit_mirror_queue_misc.erl @@ -324,10 +324,11 @@ update_mirrors(OldQ = #amqqueue{pid = QPid}, update_mirrors0(OldQ = #amqqueue{name = QName}, NewQ = #amqqueue{name = QName}) -> - All = fun (Tuple) -> [element(1, Tuple) | element(2, Tuple)] end, - OldNodes = All(actual_queue_nodes(OldQ)), - NewNodes = All(suggested_queue_nodes(NewQ)), - add_mirrors(QName, NewNodes -- OldNodes), + {OldMNode, OldSNodes, _} = actual_queue_nodes(OldQ), + {NewMNode, NewSNodes} = suggested_queue_nodes(NewQ), + OldNodes = [OldMNode | OldSNodes], + NewNodes = [NewMNode | NewSNodes], + add_mirrors (QName, NewNodes -- OldNodes), drop_mirrors(QName, OldNodes -- NewNodes), ok. |