summaryrefslogtreecommitdiff
path: root/src/rabbit_runtime_parameters.erl
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2012-03-27 15:46:40 +0100
committerSimon MacMullen <simon@rabbitmq.com>2012-03-27 15:46:40 +0100
commit02296170cf73576458edb169f81a4cc270db2142 (patch)
tree4de5de1e2fc37db69e82ce59cafa48a41227d0e6 /src/rabbit_runtime_parameters.erl
parent772fe7a6e8ce64d84b057716f48a692b65092346 (diff)
downloadrabbitmq-server-02296170cf73576458edb169f81a4cc270db2142.tar.gz
Notify when things are cleared.
Diffstat (limited to 'src/rabbit_runtime_parameters.erl')
-rw-r--r--src/rabbit_runtime_parameters.erl13
1 files changed, 8 insertions, 5 deletions
diff --git a/src/rabbit_runtime_parameters.erl b/src/rabbit_runtime_parameters.erl
index d78725df..6b7cf497 100644
--- a/src/rabbit_runtime_parameters.erl
+++ b/src/rabbit_runtime_parameters.erl
@@ -39,10 +39,13 @@ set(AppName, Key, Term) ->
ok.
clear(AppName, Key) ->
- rabbit_misc:execute_mnesia_transaction(
- fun () ->
- ok = mnesia:delete(?TABLE, {AppName, Key}, write)
- end).
+ Module = lookup_app(AppName),
+ ok = rabbit_misc:execute_mnesia_transaction(
+ fun () ->
+ ok = mnesia:delete(?TABLE, {AppName, Key}, write)
+ end),
+ Module:notify_clear(AppName, Key),
+ ok.
list() ->
[p(P) || P <- rabbit_misc:dirty_read_all(?TABLE)].
@@ -55,7 +58,7 @@ list_formatted() ->
[pset(value, format(pget(value, P)), P) || P <- list()].
lookup(AppName, Key) ->
- case value(AppName, Key) of
+ case lookup0(AppName, Key, rabbit_misc:const(not_found)) of
not_found -> not_found;
Params -> p(Params)
end.