diff options
| author | Emile Joubert <emile@rabbitmq.com> | 2012-06-07 17:00:38 +0100 |
|---|---|---|
| committer | Emile Joubert <emile@rabbitmq.com> | 2012-06-07 17:00:38 +0100 |
| commit | e56438f93b1e50457e9aad14d2e1a71cb627631f (patch) | |
| tree | a1ab642204e1fe682b65b9b476c7181e2d4b0e26 | |
| parent | 8c677526ea4ec7126f0e53d769ee2c63c3918411 (diff) | |
| download | rabbitmq-server-e56438f93b1e50457e9aad14d2e1a71cb627631f.tar.gz | |
Prevent coordinator process leakage
| -rw-r--r-- | src/rabbit_mirror_queue_coordinator.erl | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/rabbit_mirror_queue_coordinator.erl b/src/rabbit_mirror_queue_coordinator.erl index 17e2ffb4..c99fc21e 100644 --- a/src/rabbit_mirror_queue_coordinator.erl +++ b/src/rabbit_mirror_queue_coordinator.erl @@ -402,6 +402,8 @@ handle_msg([CPid], _From, request_length = Msg) -> ok = gen_server2:cast(CPid, Msg); handle_msg([CPid], _From, {ensure_monitoring, _Pids} = Msg) -> ok = gen_server2:cast(CPid, Msg); +handle_msg([_CPid], _From, {delete_and_terminate, Reason}) -> + {stop, Reason}; handle_msg([_CPid], _From, _Msg) -> ok. |