summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMichael Klishin <michael@clojurewerkz.org>2022-10-25 12:38:14 +0400
committerMichael Klishin <michael@clojurewerkz.org>2022-10-25 12:38:14 +0400
commit6f6e4b1acd8d59a63503347a076e8805893616da (patch)
tree26d67f8365c78043e105791218b24a757fd6121d
parente2a5ba5b78806456c2a188172c16af7340536bc1 (diff)
downloadrabbitmq-server-git-6f6e4b1acd8d59a63503347a076e8805893616da.tar.gz
Reduce CT logging here
-rw-r--r--deps/rabbit/test/rabbit_stream_queue_SUITE.erl4
1 files changed, 1 insertions, 3 deletions
diff --git a/deps/rabbit/test/rabbit_stream_queue_SUITE.erl b/deps/rabbit/test/rabbit_stream_queue_SUITE.erl
index 02fc475d51..457250d3c7 100644
--- a/deps/rabbit/test/rabbit_stream_queue_SUITE.erl
+++ b/deps/rabbit/test/rabbit_stream_queue_SUITE.erl
@@ -1135,7 +1135,6 @@ receive_basic_cancel_on_queue_deletion(Config) ->
recover_after_leader_and_coordinator_kill(Config) ->
[Server1 | _] = rabbit_ct_broker_helpers:get_node_configs(Config, nodename),
Ch1 = rabbit_ct_client_helpers:open_channel(Config, Server1),
- % Ch2 = rabbit_ct_client_helpers:open_channel(Config, Server1),
Q = ?config(queue_name, Config),
?assertEqual({'queue.declare_ok', Q, 0, 0},
declare(Ch1, Q, [{<<"x-queue-type">>, longstr, <<"stream">>}])),
@@ -1145,7 +1144,6 @@ recover_after_leader_and_coordinator_kill(Config) ->
QName = rabbit_misc:r(<<"/">>, queue, Q),
[begin
Sleep = rand:uniform(10),
- ct:pal("Attempt ~b Sleep ~b", [Num, Sleep]),
{ok, {_LeaderNode, LeaderPid}} = leader_info(Config),
{_, CoordNode} = get_stream_coordinator_leader(Config),
kill_stream_leader_then_coordinator_leader(Config, CoordNode,
@@ -1158,7 +1156,7 @@ recover_after_leader_and_coordinator_kill(Config) ->
rabbit_ct_broker_helpers:rpc(Config, 0, ?MODULE,
validate_writer_pid, [QName])
end)
- end || Num <- lists:seq(1, 10)],
+ end || _Num <- lists:seq(1, 10)],
{_, Node} = get_stream_coordinator_leader(Config),