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 | ee56fe363387977660d241a37a6b69de5e02eae3 (patch) | |
| tree | b2f706bfa7e385f07af4211307accd3fd30a5583 /src | |
| parent | acd9f8b65671b14bca1d63cbb86a27d907eae7d2 (diff) | |
| download | rabbitmq-server-git-ee56fe363387977660d241a37a6b69de5e02eae3.tar.gz | |
Reduce difference to default
Diffstat (limited to 'src')
| -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 30f13f1040..5ed5f063e5 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 }; |