diff options
| -rw-r--r-- | src/rabbit_recovery_indexes.erl | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/src/rabbit_recovery_indexes.erl b/src/rabbit_recovery_indexes.erl index 907f914daa..2890b2f385 100644 --- a/src/rabbit_recovery_indexes.erl +++ b/src/rabbit_recovery_indexes.erl @@ -57,7 +57,6 @@ -include("rabbit.hrl"). -define(SERVER, ?MODULE). --define(CLEAN_FILENAME, "clean.dot"). recover() -> case supervisor:start_child(rabbit_sup, @@ -73,7 +72,7 @@ upgrade_recovery_indexes() -> create_table(), try QueuesDir = filename:join(rabbit_mnesia:dir(), "queues"), - DotFiles = filelib:fold_files(QueuesDir, ?CLEAN_FILENAME, true, + DotFiles = filelib:fold_files(QueuesDir, "clean.dot", true, fun(F, Acc) -> [F|Acc] end, []), [begin {ok, Terms} = rabbit_file:read_term_file(File), @@ -132,4 +131,4 @@ create_table() -> {auto_save, infinity}]). dets_filename() -> - filename:join([rabbit_mnesia:dir(), "queues", ?CLEAN_FILENAME]). + filename:join([rabbit_mnesia:dir(), "queues", "recovery.dets"]). |