diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2013-11-06 11:43:11 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2013-11-06 11:43:11 +0000 |
| commit | 4bdce4d49de9fe81ba27cdda158214d198ce53ae (patch) | |
| tree | 43277fb77460b8c30bcf519eabb4f46b4951b064 | |
| parent | 6f3942e31c2a23b0a29a0f819314018d5fcc09f7 (diff) | |
| download | rabbitmq-server-4bdce4d49de9fe81ba27cdda158214d198ce53ae.tar.gz | |
Explain
| -rw-r--r-- | src/rabbit_mirror_queue_misc.erl | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/rabbit_mirror_queue_misc.erl b/src/rabbit_mirror_queue_misc.erl index ca36e0db..e6559841 100644 --- a/src/rabbit_mirror_queue_misc.erl +++ b/src/rabbit_mirror_queue_misc.erl @@ -98,6 +98,9 @@ remove_from_queue(QueueName, Self, LiveGMPids) -> slave_pids = SPids1, gm_pids = GMPids1}, store_updated_slaves(Q1), + %% If we add and remove nodes at the same time + %% it's possible we need to sync after removing + %% the master. Let's check. maybe_auto_sync(Q1), {ok, QPid1, [QPid | SPids] -- Alive}; _ -> |