root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Don't meck rabbit_log

This commit is contained in:
Michal Kuratczyk 2025-07-15 20:58:06 +02:00
parent 7dc4600063
commit 2943baf7d4
No known key found for this signature in database
1 changed files with 1 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
deps/rabbitmq_peer_discovery_consul/test/rabbitmq_peer_discovery_consul_SUITE.erl vendored
View File

@ -131,7 +131,6 @@ reset() ->
init_per_testcase(_TC, Config) -> init_per_testcase(_TC, Config) ->
reset(), reset(),
meck:new(rabbit_log, []),
meck:new(rabbit_peer_discovery_httpc, [passthrough]), meck:new(rabbit_peer_discovery_httpc, [passthrough]),
meck:new(rabbit_nodes, [passthrough]), meck:new(rabbit_nodes, [passthrough]),
Config. Config.
@ -508,7 +507,6 @@ list_nodes_return_value_nodes_in_warning_state_filtered_out_test(_Config) ->
?assert(meck:validate(rabbit_peer_discovery_httpc)). ?assert(meck:validate(rabbit_peer_discovery_httpc)).
registration_with_all_default_values_test(_Config) -> registration_with_all_default_values_test(_Config) ->
meck:expect(rabbit_log, debug, fun(_Message) -> ok end),
meck:expect(rabbit_peer_discovery_httpc, put, meck:expect(rabbit_peer_discovery_httpc, put,
fun(Scheme, Host, Port, Path, Args, Headers, _HttpOpts, Body) -> fun(Scheme, Host, Port, Path, Args, Headers, _HttpOpts, Body) ->
?assertEqual("http", Scheme), ?assertEqual("http", Scheme),
@ -523,7 +521,6 @@ registration_with_all_default_values_test(_Config) ->
{ok, []} {ok, []}
end), end),
?assertEqual(ok, rabbit_peer_discovery_consul:register()), ?assertEqual(ok, rabbit_peer_discovery_consul:register()),
?assert(meck:validate(rabbit_log)),
?assert(meck:validate(rabbit_peer_discovery_httpc)). ?assert(meck:validate(rabbit_peer_discovery_httpc)).
registration_with_cluster_name_test(_Config) -> registration_with_cluster_name_test(_Config) ->
@ -760,16 +757,12 @@ health_check_with_acl_token_test(_Config) ->
?assert(meck:validate(rabbit_peer_discovery_httpc)). ?assert(meck:validate(rabbit_peer_discovery_httpc)).
health_check_error_handling_test(_Config) -> health_check_error_handling_test(_Config) ->
meck:expect(rabbit_log, error, fun(_Message, _Args) ->
ok
end),
meck:expect(rabbit_peer_discovery_httpc, put, meck:expect(rabbit_peer_discovery_httpc, put,
fun(_Scheme, _Host, _Port, _Path, _Args, _Headers, _HttpOpts, _Body) -> fun(_Scheme, _Host, _Port, _Path, _Args, _Headers, _HttpOpts, _Body) ->
{error, "testing"} {error, "testing"}
end), end),
?assertEqual(ok, rabbit_peer_discovery_consul:send_health_check_pass()), ?assertEqual(ok, rabbit_peer_discovery_consul:send_health_check_pass()),
?assert(meck:validate(rabbit_peer_discovery_httpc)), ?assert(meck:validate(rabbit_peer_discovery_httpc)).
?assert(meck:validate(rabbit_log)).
unregistration_with_all_defaults_test(_Config) -> unregistration_with_all_defaults_test(_Config) ->