diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2010-07-06 10:55:13 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2010-07-06 10:55:13 +0100 |
| commit | de3269eeba1bb0efbafa40891cbcb30a7a16c9bb (patch) | |
| tree | bf6e333e8ee6628213acbcd01f687e3d63686707 | |
| parent | 5cca679cd5057a1962ef23ddbfb6e98b79b92129 (diff) | |
| download | rabbitmq-server-git-de3269eeba1bb0efbafa40891cbcb30a7a16c9bb.tar.gz | |
Forgot to fully initialise qi state.
| -rw-r--r-- | src/rabbit_queue_index.erl | 11 |
1 files changed, 7 insertions, 4 deletions
diff --git a/src/rabbit_queue_index.erl b/src/rabbit_queue_index.erl index 1f61111ccd..459c0fb67b 100644 --- a/src/rabbit_queue_index.erl +++ b/src/rabbit_queue_index.erl @@ -350,10 +350,13 @@ blank_state(QueueName) -> StrName = queue_name_to_dir_name(QueueName), Dir = filename:join(queues_dir(), StrName), ok = filelib:ensure_dir(filename:join(Dir, "nothing")), - #qistate { dir = Dir, - segments = segments_new(), - journal_handle = undefined, - dirty_count = 0 }. + {ok, MaxJournal} = + application:get_env(rabbit, queue_index_max_journal_entries), + #qistate { dir = Dir, + segments = segments_new(), + journal_handle = undefined, + dirty_count = 0, + max_journal_entries = MaxJournal }. detect_clean_shutdown(Dir) -> case file:delete(filename:join(Dir, ?CLEAN_FILENAME)) of |