summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorJerry Kuch <jerryk@vmware.com>2010-11-17 16:56:38 +0000
committerJerry Kuch <jerryk@vmware.com>2010-11-17 16:56:38 +0000
commit338941d5013675acd681a5b85f8552d3ee468165 (patch)
tree900eaa52097358b31cfad79056e15f9f3d5c6000 /src
parenta8af773cf6f73916cfbfbe0c122c0c198afa9399 (diff)
downloadrabbitmq-server-git-338941d5013675acd681a5b85f8552d3ee468165.tar.gz
Add Mnesia db migration for rabbit_durable_exchange table.
The broker should now be able to auto-upgrade both rabbit_exchange and rabbit_durable_exchange tables at boot time.
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_upgrade_functions.erl10
1 files changed, 10 insertions, 0 deletions
diff --git a/src/rabbit_upgrade_functions.erl b/src/rabbit_upgrade_functions.erl
index 2ba885d060..98db3c3b1c 100644
--- a/src/rabbit_upgrade_functions.erl
+++ b/src/rabbit_upgrade_functions.erl
@@ -28,6 +28,7 @@
-rabbit_upgrade({hash_passwords, []}).
-rabbit_upgrade({add_ip_to_listener, []}).
-rabbit_upgrade({add_internal_to_exchange, []}).
+-rabbit_upgrade({add_internal_to_durable_exchange, []}).
%% -------------------------------------------------------------------
@@ -37,6 +38,7 @@
-spec(hash_passwords/0 :: () -> 'ok').
-spec(add_ip_to_listener/0 :: () -> 'ok').
-spec(add_internal_to_exchange/0 :: () -> 'ok').
+-spec(add_internal_to_durable_exchange/0 :: () -> 'ok').
-endif.
@@ -81,6 +83,14 @@ add_internal_to_exchange() ->
end,
[name, type, durable, auto_delete, internal, arguments]).
+add_internal_to_durable_exchange() ->
+ mnesia(
+ rabbit_durable_exchange,
+ fun ({exchange, Name, Type, Durable, AutoDelete, Args}) ->
+ {exchange, Name, Type, Durable, AutoDelete, false, Args}
+ end,
+ [name, type, durable, auto_delete, internal, arguments]).
+
%%--------------------------------------------------------------------
mnesia(TableName, Fun, FieldList) ->