diff options
| author | Alvaro Videla <videlalvaro@gmail.com> | 2015-10-01 19:39:45 +0200 |
|---|---|---|
| committer | Alvaro Videla <videlalvaro@gmail.com> | 2015-10-01 19:39:45 +0200 |
| commit | 8bbd6d1e213eb1c2fb443223f5238925e4290516 (patch) | |
| tree | 1d0da2aab05b765f8b8fb8177c3df06b63b83a83 /src | |
| parent | 6ce6cb3def0cf68e084562d2e9e009f37706b256 (diff) | |
| download | rabbitmq-server-git-8bbd6d1e213eb1c2fb443223f5238925e4290516.tar.gz | |
closes the journal handle before erasing the queue index dir
Fixes #341
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_queue_index.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_queue_index.erl b/src/rabbit_queue_index.erl index 936bff1e5b..176f65b18b 100644 --- a/src/rabbit_queue_index.erl +++ b/src/rabbit_queue_index.erl @@ -269,11 +269,11 @@ reset_state(#qistate{ dir = Dir, on_sync = OnSyncFun, on_sync_msg = OnSyncMsgFun, journal_handle = JournalHdl }) -> - ok = erase_index_dir(Dir), ok = case JournalHdl of undefined -> ok; _ -> file_handle_cache:close(JournalHdl) end, + ok = erase_index_dir(Dir), blank_state_dir_funs(Dir, OnSyncFun, OnSyncMsgFun). init(Name, OnSyncFun, OnSyncMsgFun) -> |