diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-07-09 18:00:08 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-07-09 18:00:08 +0100 |
| commit | debf0ab83b7e5b4d521a575af885e05fd7ddd1a0 (patch) | |
| tree | b7ad14f01df1040ad41640642295c4152877a2f0 | |
| parent | 3432b6db0947dbdaab853f980e12aa470154368e (diff) | |
| download | rabbitmq-server-debf0ab83b7e5b4d521a575af885e05fd7ddd1a0.tar.gz | |
Fix upgrade function.
| -rw-r--r-- | src/rabbit_upgrade_functions.erl | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/src/rabbit_upgrade_functions.erl b/src/rabbit_upgrade_functions.erl index 8a44e03a..d9438d5f 100644 --- a/src/rabbit_upgrade_functions.erl +++ b/src/rabbit_upgrade_functions.erl @@ -242,16 +242,16 @@ queue_policy(Table) -> slave_pids, mirror_nodes, policy]). sync_slave_pids() -> - [ok = sync_slave_pids(T) || T <- [rabbit_queue, rabbit_durable_queue]]. - -sync_slave_pids(Table) -> - transform( - Table, - fun ({amqqueue, N, D, AD, Excl, Args, Pid, SPids, MNodes, Pol}) -> - {amqqueue, N, D, AD, Excl, Args, Pid, SPids, [], MNodes, Pol} - end, - [name, durable, auto_delete, exclusive_owner, arguments, pid, - slave_pids, sync_slave_pids, mirror_nodes, policy]). + Tables = [rabbit_queue, rabbit_durable_queue], + AddSyncSlavesFun = + fun ({amqqueue, N, D, AD, Excl, Args, Pid, SPids, MNodes, Pol}) -> + {amqqueue, N, D, AD, Excl, Args, Pid, SPids, [], MNodes, Pol} + end, + [ok = transform(T, AddSyncSlavesFun, + [name, durable, auto_delete, exclusive_owner, arguments, + pid, slave_pids, sync_slave_pids, mirror_nodes, policy]) + || T <- Tables], + ok. %%-------------------------------------------------------------------- |