Skip to content

Commit deebf54

Browse files
ansdikavgo
authored andcommitted
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 https://github.com/rabbitmq/rabbitmq-server/blob/0e803de6dd54bea8dd86290c76625c11302d2ea2/deps/rabbitmq_amqp_client/src/rabbitmq_amqp_client.erl#L411 which indicates that the client lib received a response from a previous request.
1 parent 6b30076 commit deebf54

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

deps/rabbit/test/amqp_client_SUITE.erl

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3873,7 +3873,7 @@ leader_transfer_credit(QName, QType, Credit, Config) ->
38733873
QName,
38743874
#{arguments => #{<<"x-queue-type">> => {utf8, QType},
38753875
<<"x-queue-leader-locator">> => {utf8, <<"client-local">>}}}),
3876-
60000),
3876+
60_000, 5000),
38773877
ok = close(Init),
38783878

38793879
OpnConf = connection_config(0, Config),
@@ -5456,7 +5456,7 @@ dead_letter_into_stream(Config) ->
54565456
#{arguments => #{<<"x-queue-type">> => {utf8, <<"stream">>},
54575457
<<"x-initial-cluster-size">> => {ulong, 1}
54585458
}}),
5459-
60000),
5459+
60_000, 5000),
54605460
{ok, Receiver} = amqp10_client:attach_receiver_link(
54615461
Session1, <<"receiver">>, <<"/amq/queue/", QName1/binary>>,
54625462
settled, configuration,

deps/rabbitmq_amqp_client/src/rabbitmq_amqp_client.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@
3333
set_token/2
3434
].
3535

36-
-define(TIMEOUT, 20_000).
36+
-define(TIMEOUT, 30_000).
3737
-define(MANAGEMENT_NODE_ADDRESS, <<"/management">>).
3838

3939
-type arguments() :: #{binary() => {atom(), term()}}.

0 commit comments

Comments
 (0)