diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-03-14 17:26:57 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-03-14 17:26:57 +0000 |
| commit | d917bc5cf0a8550f529bf6a4d04b73fe683e8154 (patch) | |
| tree | e8b9c86ecec212683334b859784b449fcd127415 | |
| parent | 790dd1231f26619fb6a01bb147dff9ae93f4ebe3 (diff) | |
| download | rabbitmq-server-d917bc5cf0a8550f529bf6a4d04b73fe683e8154.tar.gz | |
Comment
| -rw-r--r-- | src/rabbit_amqqueue.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index badbe7b5..c9fcec58 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -424,7 +424,8 @@ info_all(VHostPath, Items) -> map(VHostPath, fun (Q) -> info(Q, Items) end). %% We need to account for the idea that queues may be mid-promotion %% during force_event_refresh (since it's likely we're doing this in %% the first place since a node failed). Therefore we keep poking at -%% the list of queues until we were able to talk to a live process. +%% the list of queues until we were able to talk to a live process or +%% the queue no longer exists. force_event_refresh() -> force_event_refresh([Q#amqqueue.name || Q <- list()]). |