diff --git a/deps/amqp_client/test/amqp_client_SUITE.erl b/deps/amqp_client/test/amqp_client_SUITE.erl index a3e65e6460..b0a03b8ecf 100644 --- a/deps/amqp_client/test/amqp_client_SUITE.erl +++ b/deps/amqp_client/test/amqp_client_SUITE.erl @@ -48,6 +48,7 @@ consume_notification_test_() -> ?RUN([]). basic_nack_test_() -> ?RUN([]). large_content_test_() -> ?RUN([]). lifecycle_test_() -> ?RUN([]). +auth_test_() -> ?RUN([]). nowait_exchange_declare_test_() -> ?RUN([]). channel_repeat_open_close_test_() -> ?RUN([]). channel_multi_open_close_test_() -> ?RUN([]). diff --git a/deps/amqp_client/test/negative_test_util.erl b/deps/amqp_client/test/negative_test_util.erl index 2fd9aa2484..cdbfa58dec 100644 --- a/deps/amqp_client/test/negative_test_util.erl +++ b/deps/amqp_client/test/negative_test_util.erl @@ -182,8 +182,7 @@ non_existent_user_test() -> invalid_password_test() -> Params = [{username, <<"guest">>}, {password, test_util:uuid()}], - ?assertMatch({error, auth_failure}, - test_util:new_connection(just_network, Params)). + ?assertMatch({error, auth_failure}, test_util:new_connection(Params)). non_existent_vhost_test() -> Params = [{virtual_host, test_util:uuid()}], diff --git a/deps/amqp_client/test/test_util.erl b/deps/amqp_client/test/test_util.erl index 1671b1ecc9..80fa1d57d2 100644 --- a/deps/amqp_client/test/test_util.erl +++ b/deps/amqp_client/test/test_util.erl @@ -166,6 +166,11 @@ lifecycle_test() -> teardown(Connection, Channel), ok. +auth_test() -> + {ok, Connection} = new_connection(just_direct, [{password, <<"guest">>}]), + amqp_connection:close(Connection), + wait_for_death(Connection). + queue_exchange_binding(Channel, X, Parent, Tag) -> receive nothing -> ok @@ -1002,5 +1007,6 @@ make_direct_params(Props) -> proplists:get_value(Key, Props, Default) end, #amqp_params_direct{username = Pgv(username, <<"guest">>), + password = Pgv(password, none), virtual_host = Pgv(virtual_host, <<"/">>), node = Pgv(node, node())}.