summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJohn DeTreville <jdetreville@vmware.com>2011-03-27 22:47:23 -0700
committerJohn DeTreville <jdetreville@vmware.com>2011-03-27 22:47:23 -0700
commitdef8eb73452ce2c2e9604c1585693eb6f31e8c4e (patch)
tree03d2547ac82b6400211296064986804e49d98447
parent9a691de3894f11e903b1b74b86b231d0a34d6d46 (diff)
downloadrabbitmq-server-def8eb73452ce2c2e9604c1585693eb6f31e8c4e.tar.gz
Passes all tests (except as noted).
-rw-r--r--src/rabbit_mnesia_queue.erl13
1 files changed, 5 insertions, 8 deletions
diff --git a/src/rabbit_mnesia_queue.erl b/src/rabbit_mnesia_queue.erl
index c5e91ed0..72a67946 100644
--- a/src/rabbit_mnesia_queue.erl
+++ b/src/rabbit_mnesia_queue.erl
@@ -159,17 +159,14 @@ init(QueueName, IsDurable, Recover, _AsyncCallback, _SyncCallback) ->
end),
State.
-terminate(State = #state { q_table = QTable, p_table = PTable }) ->
+terminate(State = #state { p_table = PTable }) ->
{atomic, ok} = mnesia:clear_table(PTable),
- {atomic, ok} = mnesia:dump_tables([QTable, PTable]),
State.
delete_and_terminate(State = #state { q_table = QTable, p_table = PTable }) ->
- {atomic, _} =
- mnesia:transaction(fun () -> ok = clear_table(QTable),
- ok = clear_table(PTable)
- end),
- {atomic, ok} = mnesia:dump_tables([QTable, PTable]),
+ {atomic, _} = mnesia:transaction(fun () -> ok = clear_table(QTable),
+ ok = clear_table(PTable)
+ end),
State.
purge(State = #state { q_table = QTable }) ->
@@ -298,7 +295,7 @@ create_table(Table, RecordName, Type, Attributes) ->
case mnesia:create_table(Table, [{record_name, RecordName},
{type, Type},
{attributes, Attributes},
- {ram_copies, [node()]}]) of
+ {disc_copies, [node()]}]) of
{atomic, ok} -> ok;
{aborted, {already_exists, Table}} ->
RecordName = mnesia:table_info(Table, record_name),