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 | a66c1d8e5fff92f2466ba37b7aa0b55d70663cf3 (patch) | |
| tree | e8b9c86ecec212683334b859784b449fcd127415 /src | |
| parent | 2c54d455ba5b2febdab7d1ade543a7a8d699531c (diff) | |
| download | rabbitmq-server-git-a66c1d8e5fff92f2466ba37b7aa0b55d70663cf3.tar.gz | |
Comment
Diffstat (limited to 'src')
| -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 badbe7b578..c9fcec583e 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()]). |