diff options
| author | kjnilsson <knilsson@pivotal.io> | 2020-02-28 15:31:53 +0000 |
|---|---|---|
| committer | kjnilsson <knilsson@pivotal.io> | 2020-02-28 15:31:53 +0000 |
| commit | 7deac6b136939338664f939227afb4aa694eec1c (patch) | |
| tree | cb4d2f67134d87873eb05e1521a634984797d9ed /test | |
| parent | 877c1df3098af717f043e2fc8db32aae05257873 (diff) | |
| download | rabbitmq-server-git-7deac6b136939338664f939227afb4aa694eec1c.tar.gz | |
Take snapshots when messages are returnedqq-dead-letter-bug
and there is a delivery-limit in place.
Also fix rabbit_fifo tests.
Diffstat (limited to 'test')
| -rw-r--r-- | test/rabbit_fifo_SUITE.erl | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/test/rabbit_fifo_SUITE.erl b/test/rabbit_fifo_SUITE.erl index a756f4f838..8e513e5555 100644 --- a/test/rabbit_fifo_SUITE.erl +++ b/test/rabbit_fifo_SUITE.erl @@ -329,7 +329,7 @@ return_checked_out_limit_test(_) -> {State2, ok, [{send_msg, _, {delivery, _, [{MsgId2, _}]}, _}, {aux, active}]} = apply(meta(3), rabbit_fifo:make_return(Cid, [MsgId]), State1), - {#rabbit_fifo{ra_indexes = RaIdxs}, ok, []} = + {#rabbit_fifo{ra_indexes = RaIdxs}, ok, [_ReleaseEff]} = apply(meta(4), rabbit_fifo:make_return(Cid, [MsgId2]), State2), ?assertEqual(0, rabbit_fifo_index:size(RaIdxs)), ok. @@ -453,7 +453,7 @@ discarded_message_without_dead_letter_handler_is_removed_test(_) -> Effects2), ok. -discarded_message_with_dead_letter_handler_emits_mod_call_effect_test(_) -> +discarded_message_with_dead_letter_handler_emits_log_effect_test(_) -> Cid = {<<"completed_consumer_yields_demonitor_effect_test">>, self()}, State00 = init(#{name => test, queue_resource => rabbit_misc:r(<<"/">>, queue, <<"test">>), @@ -466,8 +466,7 @@ discarded_message_with_dead_letter_handler_emits_mod_call_effect_test(_) -> Effects1), {_State2, _, Effects2} = apply(meta(1), rabbit_fifo:make_discard(Cid, [0]), State1), % assert mod call effect with appended reason and message - ?ASSERT_EFF({mod_call, somemod, somefun, [somearg, [{rejected, first}]]}, - Effects2), + ?ASSERT_EFF({log, _RaftIdxs, _}, Effects2), ok. tick_test(_) -> |