diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-03-21 17:25:55 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-03-21 17:25:55 +0000 |
| commit | a32778828783ff861092e5615dcfb9377c3d0c01 (patch) | |
| tree | 696de5d004dd5a43ce3144b41c3c8fae36dcbd9f /src | |
| parent | 4d6493406ad6c98a3bd3c0a22a898deeb16f1b21 (diff) | |
| download | rabbitmq-server-git-a32778828783ff861092e5615dcfb9377c3d0c01.tar.gz | |
Notify
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_cluster_config.erl | 18 | ||||
| -rw-r--r-- | src/rabbit_cluster_config_item.erl | 3 |
2 files changed, 12 insertions, 9 deletions
diff --git a/src/rabbit_cluster_config.erl b/src/rabbit_cluster_config.erl index d4a8439512..7fd963e8e8 100644 --- a/src/rabbit_cluster_config.erl +++ b/src/rabbit_cluster_config.erl @@ -27,14 +27,16 @@ set(AppName, Key, Value) -> Term = parse(Value), validate(Term), Module:validate(Key, Term), - rabbit_misc:execute_mnesia_transaction( - fun () -> - ok = mnesia:write( - rabbit_cluster_config, - #cluster_config{key = {AppName, Key}, - value = Term}, - write) - end). + ok = rabbit_misc:execute_mnesia_transaction( + fun () -> + ok = mnesia:write( + rabbit_cluster_config, + #cluster_config{key = {AppName, Key}, + value = Term}, + write) + end), + Module:notify(Key, Term), + ok. clear(AppName, Key) -> rabbit_misc:execute_mnesia_transaction( diff --git a/src/rabbit_cluster_config_item.erl b/src/rabbit_cluster_config_item.erl index 4ab903eaa7..093e92b58c 100644 --- a/src/rabbit_cluster_config_item.erl +++ b/src/rabbit_cluster_config_item.erl @@ -20,7 +20,8 @@ behaviour_info(callbacks) -> [ - {validate, 2} + {validate, 2}, + {notify, 2} ]; behaviour_info(_Other) -> undefined. |