diff options
| -rw-r--r-- | src/rabbit_disk_queue.erl | 1 | ||||
| -rw-r--r-- | src/rabbit_mnesia.erl | 4 |
2 files changed, 3 insertions, 2 deletions
diff --git a/src/rabbit_disk_queue.erl b/src/rabbit_disk_queue.erl index 26aa9d4b2c..f0fab00d88 100644 --- a/src/rabbit_disk_queue.erl +++ b/src/rabbit_disk_queue.erl @@ -102,6 +102,7 @@ clean_stop() -> init([FileSizeLimit, ReadFileHandlesLimit]) -> process_flag(trap_exit, true), + ok = filelib:ensure_dir(form_filename("nothing")), InitName = "0" ++ ?FILE_EXTENSION, {ok, MsgLocation} = dets:open_file(?MSG_LOC_DETS_NAME, [{file, form_filename(atom_to_list(?MSG_LOC_DETS_NAME) ++ ?FILE_EXTENSION_DETS)}, diff --git a/src/rabbit_mnesia.erl b/src/rabbit_mnesia.erl index 858b024acf..b3c4a9267e 100644 --- a/src/rabbit_mnesia.erl +++ b/src/rabbit_mnesia.erl @@ -146,9 +146,9 @@ table_definitions() -> {attributes, record_info(fields, amqqueue)}]}, {rabbit_disk_queue, [{record_name, dq_msg_loc}, - {type, ordered_set}, + {type, set}, {attributes, record_info(fields, dq_msg_loc)}, - {disc_copies, [node()]}]} + {disc_only_copies, [node()]}]} ]. table_names() -> |