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

Merge pull request #14007 from rabbitmq/backpressure-flake 

Remove AMQP backpressure test expectation
This commit is contained in:
Michael Klishin 2025-06-02 23:00:12 +04:00 committed by GitHub
parent e19d2b0163 0c391a52d3
commit 797e54330b
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
deps/rabbit/test/amqp_client_SUITE.erl vendored
View File

@ -6254,18 +6254,10 @@ tcp_back_pressure_rabbitmq_internal_flow(QType, Config) ->
?assert(MsgsReady > 0),
?assert(MsgsReady < Num),
%% Use large buffers. This will considerably speed up receiving all messages (on Linux).
ok = inet:setopts(Socket, [{recbuf, 65536},
{buffer, 65536}]),
%% When we resume the receiving client, we expect to receive all messages.
?assert(meck:validate(Mod)),
ok = meck:unload(Mod),
ok = Mod:setopts(Socket, [{active, once}]),
receive_messages(Receiver, Num),
ok = detach_link_sync(Receiver),
{ok, #{message_count := 0}} = rabbitmq_amqp_client:delete_queue(LinkPair, QName),
ok = close({Connection, Session, LinkPair}).
%% Rely on end_per_testcase/2 to delete the queue and to close the connection.
ok.
session_flow_control_default_max_frame_size(Config) ->
QName = atom_to_binary(?FUNCTION_NAME),