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

Bump timeout in RabbitMQ AMQP 1.0 Erlang client 

Bump the timeout for management operations and link attachments from 20s
to 30s. We've seen timeouts in CI.

We bump the poll interval of the `?awaitMatch` macro because CI
sometimes flaked by crashing in
0e803de6dd/deps/rabbitmq_amqp_client/src/rabbitmq_amqp_client.erl (L411)
which indicates that the client lib received a response from a previous
request.
This commit is contained in:
David Ansari 2025-03-27 09:51:56 +01:00 committed by David Ansari
parent 0e803de6dd
commit 44657cd393
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -3873,7 +3873,7 @@ leader_transfer_credit(QName, QType, Credit, Config) ->
QName, QName,
#{arguments => #{<<"x-queue-type">> => {utf8, QType}, #{arguments => #{<<"x-queue-type">> => {utf8, QType},
<<"x-queue-leader-locator">> => {utf8, <<"client-local">>}}}), <<"x-queue-leader-locator">> => {utf8, <<"client-local">>}}}),
60000), 60_000, 5000),
ok = close(Init), ok = close(Init),
OpnConf = connection_config(0, Config), OpnConf = connection_config(0, Config),
@ -5456,7 +5456,7 @@ dead_letter_into_stream(Config) ->
#{arguments => #{<<"x-queue-type">> => {utf8, <<"stream">>}, #{arguments => #{<<"x-queue-type">> => {utf8, <<"stream">>},
<<"x-initial-cluster-size">> => {ulong, 1} <<"x-initial-cluster-size">> => {ulong, 1}
}}), }}),
60000), 60_000, 5000),
{ok, Receiver} = amqp10_client:attach_receiver_link( {ok, Receiver} = amqp10_client:attach_receiver_link(
Session1, <<"receiver">>, <<"/amq/queue/", QName1/binary>>, Session1, <<"receiver">>, <<"/amq/queue/", QName1/binary>>,
settled, configuration, settled, configuration,

2
deps/rabbitmq_amqp_client/src/rabbitmq_amqp_client.erl vendored
View File

@ -33,7 +33,7 @@
set_token/2 set_token/2
]. ].
-define(TIMEOUT, 20_000). -define(TIMEOUT, 30_000).
-define(MANAGEMENT_NODE_ADDRESS, <<"/management">>). -define(MANAGEMENT_NODE_ADDRESS, <<"/management">>).
-type arguments() :: #{binary() => {atom(), term()}}. -type arguments() :: #{binary() => {atom(), term()}}.