diff options
| -rw-r--r-- | src/rabbit_quorum_queue.erl | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/src/rabbit_quorum_queue.erl b/src/rabbit_quorum_queue.erl index 33f8166da6..12c651eeb1 100644 --- a/src/rabbit_quorum_queue.erl +++ b/src/rabbit_quorum_queue.erl @@ -1000,6 +1000,11 @@ delete_member(Q, Node) when ?amqqueue_is_quorum(Q) -> case ra:force_delete_server(ServerId) of ok -> ok; + {error, {badrpc, nodedown}} -> + ok; + {error, {badrpc, {'EXIT', {badarg, _}}}} -> + %% DETS/ETS tables can't be found, application isn't running + ok; {error, _} = Err -> Err; Err -> @@ -1007,6 +1012,8 @@ delete_member(Q, Node) when ?amqqueue_is_quorum(Q) -> end; {timeout, _} -> {error, timeout}; + {badrpc, nodedown} -> + ok; E -> E end |