diff options
| author | Matthew Sackman <matthew@lshift.net> | 2009-10-16 14:55:41 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@lshift.net> | 2009-10-16 14:55:41 +0100 |
| commit | d36651e3f53e4be5f96752611e81fb924380a793 (patch) | |
| tree | aa209e58b144e1a19b698d5716e79a8317671efe /src | |
| parent | 4dfaaebf75782966558879647dc84a1787850db9 (diff) | |
| download | rabbitmq-server-git-d36651e3f53e4be5f96752611e81fb924380a793.tar.gz | |
Bug fix.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_queue_index.erl | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/src/rabbit_queue_index.erl b/src/rabbit_queue_index.erl index 9933eb4cd8..e74ef2953d 100644 --- a/src/rabbit_queue_index.erl +++ b/src/rabbit_queue_index.erl @@ -308,9 +308,12 @@ start_msg_store() -> DurableQueueNames = sets:from_list([ queue_name_to_dir_name(Queue #amqqueue.name) || Queue <- DurableQueues ]), - Directories = case file:list_dir(queues_dir()) of + QueuesDir = queues_dir(), + Directories = case file:list_dir(QueuesDir) of {ok, Entries} -> - [ Entry || Entry <- Entries, filelib:is_dir(Entry) ]; + [ Entry || Entry <- Entries, + filelib:is_dir( + filename:join(QueuesDir, Entry)) ]; {error, enoent} -> [] end, |