summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorMatthew Sackman <matthew@rabbitmq.com>2011-06-21 14:14:14 +0100
committerMatthew Sackman <matthew@rabbitmq.com>2011-06-21 14:14:14 +0100
commit30f4103decf18fd4163aedccf35760eb19c4718a (patch)
treef3ed408d9d0843c9fad747e4675f84931eb994c3 /src
parente7c1d76dca8b4081172d816244eeb18ada5ce98a (diff)
downloadrabbitmq-server-30f4103decf18fd4163aedccf35760eb19c4718a.tar.gz
Rip out support for dynamically adding or removing queue mirrors
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_control.erl12
1 files changed, 0 insertions, 12 deletions
diff --git a/src/rabbit_control.erl b/src/rabbit_control.erl
index 9194a45b..9eef384a 100644
--- a/src/rabbit_control.erl
+++ b/src/rabbit_control.erl
@@ -274,18 +274,6 @@ 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(drop_queue_mirror, Node, [Queue, MirrorNode], Opts, Inform) ->
- Inform("Dropping 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, drop_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)),