Skip to content

Commit 960cd60

Browse files
committed
Fix Receiver
1 parent f418595 commit 960cd60

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

deps/rabbit/test/amqp_client_SUITE.erl

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -388,23 +388,26 @@ delivery_count(QType, Config) ->
388388
first_acquirer := true},
389389
amqp10_msg:headers(Msg1)),
390390

391-
%% delivery-failed=true in modified coutcome must increment the delivery-count
392391
%% delivery-failed=false in modified coutcome must not increment the delivery-count
393392
ok = amqp10_client:settle_msg(QReceiver, Msg1, {modified, false, false, #{}}),
394393
{ok, Msg2} = amqp10_client:get_msg(QReceiver),
395394
?assertMatch(#{delivery_count := 0,
396395
first_acquirer := false},
397396
amqp10_msg:headers(Msg2)),
397+
398+
%% delivery-failed=true in modified coutcome must increment the delivery-count
398399
ok = amqp10_client:settle_msg(QReceiver, Msg2, {modified, true, false, #{}}),
399400
{ok, Msg3} = amqp10_client:get_msg(QReceiver),
400401
?assertMatch(#{delivery_count := 1,
401402
first_acquirer := false},
402403
amqp10_msg:headers(Msg3)),
403-
ok = amqp10_client:settle_msg(DLQReceiver, Msg3, {modified, true, true, #{}}),
404+
405+
ok = amqp10_client:settle_msg(QReceiver, Msg3, {modified, true, true, #{}}),
404406
{ok, Msg4} = amqp10_client:get_msg(DLQReceiver),
405407
?assertMatch(#{delivery_count := 2,
406408
first_acquirer := false},
407409
amqp10_msg:headers(Msg4)),
410+
408411
ok = amqp10_client:settle_msg(DLQReceiver, Msg4, {modified, false, true, #{}}),
409412
{ok, Msg5} = amqp10_client:get_msg(QReceiver),
410413
?assertMatch(#{delivery_count := 2,

0 commit comments

Comments
 (0)