diff options
| author | Diana Corbacho <diana@rabbitmq.com> | 2018-11-06 13:53:48 +0000 |
|---|---|---|
| committer | Diana Corbacho <diana@rabbitmq.com> | 2018-11-06 13:53:48 +0000 |
| commit | d098858a2152776ec316799d636a3ad24861fc64 (patch) | |
| tree | b1b8086c55b0b074dc09008351a291cf4560a21b /src | |
| parent | 84fb288e45e440a170686dd8acfb0730c6911af8 (diff) | |
| download | rabbitmq-server-git-d098858a2152776ec316799d636a3ad24861fc64.tar.gz | |
Handle errors while deleting quorum queue on minority
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_quorum_queue.erl | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/src/rabbit_quorum_queue.erl b/src/rabbit_quorum_queue.erl index 795465855b..4823d4ef32 100644 --- a/src/rabbit_quorum_queue.erl +++ b/src/rabbit_quorum_queue.erl @@ -281,7 +281,7 @@ delete(#amqqueue{ type = quorum, pid = {Name, _}, name = QName, quorum_nodes = Q end, rpc:call(LeaderNode, rabbit_core_metrics, queue_deleted, [QName]), {ok, Msgs}; - {error, {no_more_nodes_to_try, Errs}} = Err -> + {error, {no_more_servers_to_try, Errs}} -> case lists:all(fun({{error, noproc}, _}) -> true; (_) -> false end, Errs) of @@ -291,7 +291,10 @@ delete(#amqqueue{ type = quorum, pid = {Name, _}, name = QName, quorum_nodes = Q rabbit_core_metrics:queue_deleted(QName), {ok, Msgs}; false -> - Err + rabbit_misc:protocol_error( + internal_error, + "Cannot delete queue '~s', servers unavailable: ~255p", + [rabbit_misc:rs(QName), Errs]) end end. |
