diff options
| author | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2020-02-28 17:18:14 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-02-28 17:18:14 +0100 |
| commit | 3653d237f5dff7603c4f578bbb5a6ddbc919b786 (patch) | |
| tree | cb4d2f67134d87873eb05e1521a634984797d9ed /test | |
| parent | 7aa77b2f0b832fd1fd4fa08f8e0ef86a7009e1fe (diff) | |
| parent | 7deac6b136939338664f939227afb4aa694eec1c (diff) | |
| download | rabbitmq-server-git-3653d237f5dff7603c4f578bbb5a6ddbc919b786.tar.gz | |
Merge pull request #2263 from rabbitmq/qq-dead-letter-bug
Take snapshots when messages are returned
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(_) -> |