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 | 62e4f7f7f0d9a8c5c94faa99a8b57106bfe7f363 (patch) | |
| tree | a1ab642204e1fe682b65b9b476c7181e2d4b0e26 /src | |
| parent | 707e264eb285811ec61628a14ee24c830055d881 (diff) | |
| download | rabbitmq-server-git-62e4f7f7f0d9a8c5c94faa99a8b57106bfe7f363.tar.gz | |
Prevent coordinator process leakage
Diffstat (limited to 'src')
| -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 17e2ffb472..c99fc21eb3 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. |