We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2e7a30a commit f193b72Copy full SHA for f193b72
deps/rabbitmq_stream/test/rabbit_stream_partitions_SUITE.erl
@@ -250,7 +250,7 @@ super_stream_sac_consumer_should_get_disconnected_on_network_partition(Config) -
250
Acc#{K => {S0, C0}}
251
end, #{}, SubIdToState0),
252
253
- delete_super_stream(Config, Ss),
+ delete_super_stream(Config, Ss, L#node.stream_port),
254
255
%% online consumers should receive a metadata update frame (stream deleted)
256
%% we unqueue this frame before closing the connection
@@ -344,8 +344,8 @@ init_super_stream(Config, Ss) ->
344
{ok, _} = stream_test_utils:close(S, C1),
345
Partitions.
346
347
-delete_super_stream(Config, Ss) ->
348
- {ok, S, C0} = stream_test_utils:connect(Config, 0),
+delete_super_stream(Config, Ss, Port) ->
+ {ok, S, C0} = stream_test_utils:connect(Port),
349
SsDeletionFrame = request({delete_super_stream, Ss}),
350
ok = ?TRSPT:send(S, SsDeletionFrame),
351
{Cmd1, C1} = receive_commands(S, C0),
0 commit comments