Cancel sync

1 files changed, 7 insertions, 0 deletions

diff --git a/src/rabbit_control_main.erl b/src/rabbit_control_main.erl
index b4272555..12096ff5 100644
--- a/src/rabbit_control_main.erl
+++ b/src/rabbit_control_main.erl
@@ -51,6 +51,7 @@
          {forget_cluster_node, [?OFFLINE_DEF]},
          cluster_status,
          {sync_queue, [?VHOST_DEF]},
+         {cancel_sync_queue, [?VHOST_DEF]},
 
          add_user,
          delete_user,
@@ -287,6 +288,12 @@ action(sync_queue, Node, [Queue], Opts, Inform) ->
     rpc_call(Node, rabbit_amqqueue, sync,
              [list_to_binary(Queue), list_to_binary(VHost)]);
 
+action(cancel_sync_queue, Node, [Queue], Opts, Inform) ->
+    VHost = proplists:get_value(?VHOST_OPT, Opts),
+    Inform("Stopping synchronising queue ~s in ~s", [Queue, VHost]),
+    rpc_call(Node, rabbit_amqqueue, cancel_sync,
+             [list_to_binary(Queue), list_to_binary(VHost)]);
+
 action(wait, Node, [PidFile], _Opts, Inform) ->
     Inform("Waiting for ~p", [Node]),
     wait_for_application(Node, PidFile, rabbit_and_plugins, Inform);