Shovel tests: test disk alarm

(cherry picked from commit c0b118a)

Author: dcorbacho

deps/rabbitmq_shovel/test/shovel_dynamic_SUITE.erl

@@ -108,7 +108,8 @@ tests() ->
      application_properties,
      delete_src_queue,
      shovel_status,
-     change_definition
+     change_definition,
+     disk_alarm
     ].
 
 %% -------------------------------------------------------------------
@@ -594,6 +595,20 @@ change_definition(Config) ->
               amqp10_expect_empty(Sess, Dest2)
       end).
 
+disk_alarm(Config) ->
+    Src = ?config(srcq, Config),
+    Dest = ?config(destq, Config),
+    with_amqp10_session(Config,
+      fun (Sess) ->
+              ShovelArgs = ?config(shovel_args, Config),
+              amqp10_publish(Sess, Src, <<"hello">>, 10),
+              rabbit_ct_broker_helpers:set_alarm(Config, 0, disk),
+              set_param(Config, ?PARAM, ShovelArgs),
+              amqp10_expect_empty(Sess, Dest),
+              rabbit_ct_broker_helpers:clear_alarm(Config, 0, disk),
+              amqp10_expect_count(Sess, Dest, 10)
+      end).
+
 %%----------------------------------------------------------------------------
 maybe_skip_local_protocol(Config) ->
     [Node] = rabbit_ct_broker_helpers:get_node_configs(Config, nodename),