diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-06-25 15:43:27 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-06-25 15:43:27 +0100 |
| commit | bab700b30c7780e328762fce77da82dc0529117c (patch) | |
| tree | 3c8957df2d118d1e73a01d215049338c1094c4a4 | |
| parent | 648efa8eb736011c9324f024bd9981ba04348114 (diff) | |
| download | rabbitmq-server-git-bab700b30c7780e328762fce77da82dc0529117c.tar.gz | |
Close down the slave's GM the same way the master's GM does.
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index e412fbbc5d..2109bdd874 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -351,10 +351,15 @@ handle_msg([_SPid], _From, {ensure_monitoring, _Pid}) -> ok; handle_msg([SPid], _From, {process_death, Pid}) -> inform_deaths(SPid, [Pid]); +handle_msg([CPid], _From, {delete_and_terminate, Reason} = Msg) -> + ok = gen_server2:cast(CPid, {gm, Msg}), + {stop, Reason}; handle_msg([SPid], _From, Msg) -> ok = gen_server2:cast(SPid, {gm, Msg}). inform_deaths(SPid, Deaths) -> + %% TODO can we get rid of this with_exit_handler use? See bug + %% 24988 comment 13. rabbit_misc:with_exit_handler( fun () -> {stop, normal} end, fun () -> |