Skip to content

Commit 797e543

Browse files
Merge pull request #14007 from rabbitmq/backpressure-flake
Remove AMQP backpressure test expectation
2 parents e19d2b0 + 0c391a5 commit 797e543

File tree

1 file changed

+2
-10
lines changed

1 file changed

+2
-10
lines changed

deps/rabbit/test/amqp_client_SUITE.erl

Lines changed: 2 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -6254,18 +6254,10 @@ tcp_back_pressure_rabbitmq_internal_flow(QType, Config) ->
62546254
?assert(MsgsReady > 0),
62556255
?assert(MsgsReady < Num),
62566256

6257-
%% Use large buffers. This will considerably speed up receiving all messages (on Linux).
6258-
ok = inet:setopts(Socket, [{recbuf, 65536},
6259-
{buffer, 65536}]),
6260-
%% When we resume the receiving client, we expect to receive all messages.
62616257
?assert(meck:validate(Mod)),
62626258
ok = meck:unload(Mod),
6263-
ok = Mod:setopts(Socket, [{active, once}]),
6264-
receive_messages(Receiver, Num),
6265-
6266-
ok = detach_link_sync(Receiver),
6267-
{ok, #{message_count := 0}} = rabbitmq_amqp_client:delete_queue(LinkPair, QName),
6268-
ok = close({Connection, Session, LinkPair}).
6259+
%% Rely on end_per_testcase/2 to delete the queue and to close the connection.
6260+
ok.
62696261

62706262
session_flow_control_default_max_frame_size(Config) ->
62716263
QName = atom_to_binary(?FUNCTION_NAME),

0 commit comments

Comments
 (0)