diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-09-05 10:08:51 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-09-05 10:08:51 +0100 |
| commit | 4d81ce03d196bf97ce3fda8969095e00e895d6ee (patch) | |
| tree | b2f706bfa7e385f07af4211307accd3fd30a5583 | |
| parent | ec065fc0092059e9ddf2fb6e2fb88d48ce8ce793 (diff) | |
| download | rabbitmq-server-4d81ce03d196bf97ce3fda8969095e00e895d6ee.tar.gz | |
Reduce difference to default
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index 30f13f10..5ed5f063 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -927,9 +927,9 @@ set_synchronised(true, State = #state { q = #amqqueue { name = QName }, case mnesia:read({rabbit_queue, QName}) of [] -> ok; - [Q = #amqqueue{sync_slave_pids = SSPids}] -> - Q1 = Q#amqqueue{sync_slave_pids = [Self | SSPids]}, - rabbit_mirror_queue_misc:store_updated_slaves(Q1) + [Q1 = #amqqueue{sync_slave_pids = SSPids}] -> + Q2 = Q1#amqqueue{sync_slave_pids = [Self | SSPids]}, + rabbit_mirror_queue_misc:store_updated_slaves(Q2) end end), State #state { synchronised = true }; |