diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2016-06-23 02:54:47 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2016-06-23 02:54:47 +0300 |
| commit | 59280327de479a62428c3dacac8f74a663c56078 (patch) | |
| tree | 4b046fad07d951e23cbde64865a5e793cb99ed43 /deps | |
| parent | b8f8d983dc13b48636752c2390046a41e932119b (diff) | |
| download | rabbitmq-server-git-59280327de479a62428c3dacac8f74a663c56078.tar.gz | |
Introduce parameter management helpers
Diffstat (limited to 'deps')
| -rw-r--r-- | deps/rabbit_common/src/rabbit_ct_broker_helpers.erl | 19 |
1 files changed, 19 insertions, 0 deletions
diff --git a/deps/rabbit_common/src/rabbit_ct_broker_helpers.erl b/deps/rabbit_common/src/rabbit_ct_broker_helpers.erl index 24d8eeb5f9..5086c8c643 100644 --- a/deps/rabbit_common/src/rabbit_ct_broker_helpers.erl +++ b/deps/rabbit_common/src/rabbit_ct_broker_helpers.erl @@ -51,6 +51,9 @@ get_connection_pids/1, get_queue_sup_pid/1, + set_parameter/5, + clear_parameter/4, + set_policy/6, clear_policy/3, set_ha_policy/4, set_ha_policy/5, @@ -739,6 +742,22 @@ get_queue_sup_pid([{_, SupPid, _, _} | Rest], QueuePid) -> get_queue_sup_pid([], _QueuePid) -> undefined. + +%% ------------------------------------------------------------------- +%% Runtime parameter helpers. +%% ------------------------------------------------------------------- + +set_parameter(Config, Node, Component, Key, Value) -> + ok = rpc(Config, Node, + rabbit_runtime_parameters, parse_set, + [<<"/">>, Component, Key, Value, none]). + +clear_parameter(Config, Node, Component, Key) -> + ok = rpc(Config, Node, + rabbit_runtime_parameters, clear, + [<<"/">>, Component, Key]). + + %% ------------------------------------------------------------------- %% Policy helpers. %% ------------------------------------------------------------------- |