Skip to content

Commit b624ae8

Browse files
committed
shovel tests: unsettled mode in amqp10_expect_empty
This should address some CI flakes. With settled mode, if a message was dispatched to a consumer after the 500ms timeout but before the link detached, this message would be effectively consumed and therefore removed from the queue, leading to an unexpected queue length.
1 parent f9d28de commit b624ae8

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

deps/rabbitmq_shovel/test/shovel_test_utils.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -259,7 +259,7 @@ amqp10_publish_msg(Sender, Tag, Msg) ->
259259
amqp10_expect_empty(Session, Dest) ->
260260
LinkName = <<"dynamic-receiver-", Dest/binary>>,
261261
{ok, Receiver} = amqp10_client:attach_receiver_link(Session, LinkName,
262-
Dest, settled,
262+
Dest, unsettled,
263263
unsettled_state),
264264
ok = amqp10_client:flow_link_credit(Receiver, 1, never),
265265
receive

0 commit comments

Comments
 (0)