Tests: auth_SUITE close all connections in end_per_testcase

Author: dcorbacho

deps/rabbitmq_mqtt/test/auth_SUITE.erl

@@ -393,21 +393,25 @@ end_per_testcase(Testcase, Config) when Testcase == ssl_user_auth_success;
                                         Testcase == ssl_user_auth_failure;
                                         Testcase == ssl_user_vhost_not_allowed ->
     delete_cert_user(Config),
+    close_all_connections(Config),
     rabbit_ct_helpers:testcase_finished(Config, Testcase);
 end_per_testcase(TestCase, Config) when TestCase == ssl_user_vhost_parameter_mapping_success;
                                         TestCase == ssl_user_vhost_parameter_mapping_not_allowed ->
     delete_cert_user(Config),
     VhostForCertUser = ?config(temp_vhost_for_ssl_user, Config),
     ok = rabbit_ct_broker_helpers:delete_vhost(Config, VhostForCertUser),
     ok = rabbit_ct_broker_helpers:clear_global_parameter(Config, mqtt_default_vhosts),
+    close_all_connections(Config),
     rabbit_ct_helpers:testcase_finished(Config, TestCase);
 end_per_testcase(user_credentials_auth, Config) ->
     User = ?config(new_user, Config),
     {ok,_} = rabbit_ct_broker_helpers:rabbitmqctl(Config, 0, ["delete_user", User]),
+    close_all_connections(Config),
     rabbit_ct_helpers:testcase_finished(Config, user_credentials_auth);
 end_per_testcase(ssl_user_vhost_parameter_mapping_vhost_does_not_exist, Config) ->
     delete_cert_user(Config),
     ok = rabbit_ct_broker_helpers:clear_global_parameter(Config, mqtt_default_vhosts),
+    close_all_connections(Config),
     rabbit_ct_helpers:testcase_finished(Config, ssl_user_vhost_parameter_mapping_vhost_does_not_exist);
 end_per_testcase(Testcase, Config) when Testcase == port_vhost_mapping_success;
                                         Testcase == port_vhost_mapping_not_allowed;
@@ -417,11 +421,13 @@ end_per_testcase(Testcase, Config) when Testcase == port_vhost_mapping_success;
     VHost = ?config(temp_vhost_for_port_mapping, Config),
     ok = rabbit_ct_broker_helpers:delete_vhost(Config, VHost),
     ok = rabbit_ct_broker_helpers:clear_global_parameter(Config, mqtt_port_to_vhost_mapping),
+    close_all_connections(Config),
     rabbit_ct_helpers:testcase_finished(Config, Testcase);
 end_per_testcase(T = port_vhost_mapping_vhost_does_not_exist, Config) ->
     User = <<"guest">>,
     ok = set_full_permissions(Config, User, <<"/">>),
     ok = rabbit_ct_broker_helpers:clear_global_parameter(Config, mqtt_port_to_vhost_mapping),
+    close_all_connections(Config),
     rabbit_ct_helpers:testcase_finished(Config, T);
 end_per_testcase(T = ssl_user_cert_vhost_mapping_takes_precedence_over_port_vhost_mapping, Config) ->
     delete_cert_user(Config),
@@ -432,6 +438,7 @@ end_per_testcase(T = ssl_user_cert_vhost_mapping_takes_precedence_over_port_vhos
     VHostForPortVHostMapping = ?config(temp_vhost_for_port_mapping, Config),
     ok = rabbit_ct_broker_helpers:delete_vhost(Config, VHostForPortVHostMapping),
     ok = rabbit_ct_broker_helpers:clear_global_parameter(Config, mqtt_port_to_vhost_mapping),
+    close_all_connections(Config),
     rabbit_ct_helpers:testcase_finished(Config, T);
 end_per_testcase(T, Config) when T == queue_bind_permission;
                                  T == queue_unbind_permission;
@@ -459,6 +466,8 @@ end_per_testcase(T, Config) when T == queue_bind_permission;
     %% And provide an empty log file for the next test in this group
     file:write_file(?config(log_location, Config), <<>>),
 
+    close_all_connections(Config),
+
     rabbit_ct_helpers:testcase_finished(Config, T);
 
 end_per_testcase(T, Config) 
@@ -469,11 +478,17 @@ end_per_testcase(T, Config)
        T =:= client_id_from_cert_san_email;
        T =:= client_id_from_cert_dn ->
     SetupProcess = ?config(mock_setup_process, Config),
-    SetupProcess ! stop;
+    SetupProcess ! stop,
+    close_all_connections(Config);
 
 end_per_testcase(Testcase, Config) ->
+    close_all_connections(Config),
     rabbit_ct_helpers:testcase_finished(Config, Testcase).
 
+close_all_connections(Config) ->
+    rpc(Config, 0, rabbit_mqtt, close_local_client_connections,
+        [end_per_testcase]).
+
 delete_cert_user(Config) ->
     User = ?config(temp_ssl_user, Config),
     {ok,_} = rabbit_ct_broker_helpers:rabbitmqctl(Config, 0, ["delete_user", User]).