diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-09-10 11:59:06 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-09-10 11:59:06 +0100 |
| commit | 5eb6dbe387b1aa93241333411aecb819bd9c864c (patch) | |
| tree | 411e17a69caaf4074523fc9db6df956db1af45b2 /src/rabbit_mirror_queue_misc.erl | |
| parent | 183007616bc81421ccd0bdf96f333591ca637b83 (diff) | |
| download | rabbitmq-server-5eb6dbe387b1aa93241333411aecb819bd9c864c.tar.gz | |
Further reduce distance to default (especially in slave), by getting the prequeue to pass straight into the right module at the end of init/1.
Diffstat (limited to 'src/rabbit_mirror_queue_misc.erl')
| -rw-r--r-- | src/rabbit_mirror_queue_misc.erl | 5 |
1 files changed, 1 insertions, 4 deletions
diff --git a/src/rabbit_mirror_queue_misc.erl b/src/rabbit_mirror_queue_misc.erl index 5cb871e8..aec6f93d 100644 --- a/src/rabbit_mirror_queue_misc.erl +++ b/src/rabbit_mirror_queue_misc.erl @@ -210,10 +210,7 @@ add_mirror(QName, MirrorNode, SyncMode) -> MirrorNode, Q, slave), log_info(QName, "Adding mirror on node ~p: ~p~n", [MirrorNode, SPid]), - case SyncMode of - sync -> rabbit_mirror_queue_slave:await(SPid); - async -> ok - end + rabbit_mirror_queue_slave:go(SPid, SyncMode) end); {error, not_found} = E -> E |