diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2011-03-11 12:27:33 +0000 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2011-03-11 12:27:33 +0000 |
| commit | eb8c2af1781252b6a1eb8d5d65d40f04f589d169 (patch) | |
| tree | 16d5d778c89a4df9415d7ff9b1e8d4b2c4bef2dc /src/rabbit_control.erl | |
| parent | 7dcf94336ae74594c7ed44b8648830a677c3e696 (diff) | |
| download | rabbitmq-server-eb8c2af1781252b6a1eb8d5d65d40f04f589d169.tar.gz | |
Add ability to dynamically add slaves
Diffstat (limited to 'src/rabbit_control.erl')
| -rw-r--r-- | src/rabbit_control.erl | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/src/rabbit_control.erl b/src/rabbit_control.erl index e2c050f5..604b1bfa 100644 --- a/src/rabbit_control.erl +++ b/src/rabbit_control.erl @@ -232,6 +232,12 @@ action(list_queues, Node, Args, Opts, Inform) -> [VHostArg, ArgAtoms]), ArgAtoms); +action(add_queue_mirror, Node, [Queue, MirrorNode], Opts, Inform) -> + Inform("Adding mirror of queue ~p on node ~p~n", [Queue, MirrorNode]), + VHostArg = list_to_binary(proplists:get_value(?VHOST_OPT, Opts)), + rpc_call(Node, rabbit_mirror_queue_misc, add_slave, + [VHostArg, list_to_binary(Queue), list_to_atom(MirrorNode)]); + action(list_exchanges, Node, Args, Opts, Inform) -> Inform("Listing exchanges", []), VHostArg = list_to_binary(proplists:get_value(?VHOST_OPT, Opts)), |