rabbit_stream_queue_SUITE

Author: dumbbell

deps/rabbit/test/rabbit_stream_queue_SUITE.erl

@@ -723,6 +723,7 @@ shrink_coordinator_cluster(Config) ->
 
     ?assertEqual({'queue.declare_ok', Q, 0, 0},
                  declare(Config, Server0, Q, [{<<"x-queue-type">>, longstr, <<"stream">>}])),
+    check_leader_and_replicas(Config, [Server0, Server1, Server2]),
 
     ok = rabbit_control_helper:command(stop_app, Server2),
     ok = rabbit_control_helper:command(forget_cluster_node, Server0, [atom_to_list(Server2)], []),