diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2011-07-26 18:39:12 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2011-07-26 18:39:12 +0100 |
| commit | a3bc422fa3e94686025d651f9326bb90c46f5158 (patch) | |
| tree | 625444aceab58a7b03a09081f02f1b80b5721c7f /src/rabbit_mirror_queue_slave.erl | |
| parent | 9433b14ae3f0e864895b0b02837b7598cadfe32c (diff) | |
| download | rabbitmq-server-a3bc422fa3e94686025d651f9326bb90c46f5158.tar.gz | |
Wipe out slave pids whenever we start up a queue.
Diffstat (limited to 'src/rabbit_mirror_queue_slave.erl')
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index b38a8967..84efb7ca 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -89,9 +89,8 @@ init([#amqqueue { name = QueueName } = Q]) -> %% ASSERTION [] = [Pid || Pid <- [QPid | MPids], node(Pid) =:= Node], MPids1 = MPids ++ [Self], - mnesia:write(rabbit_queue, - Q1 #amqqueue { slave_pids = MPids1 }, - write), + ok = rabbit_amqqueue:store_queue( + Q1 #amqqueue { slave_pids = MPids1 }), {ok, QPid} end), erlang:monitor(process, MPid), |