diff options
Diffstat (limited to 'test')
| -rw-r--r-- | test/quorum_queue_SUITE.erl | 16 |
1 files changed, 16 insertions, 0 deletions
diff --git a/test/quorum_queue_SUITE.erl b/test/quorum_queue_SUITE.erl index 64a2dc4205..0fd76dd0fb 100644 --- a/test/quorum_queue_SUITE.erl +++ b/test/quorum_queue_SUITE.erl @@ -107,6 +107,7 @@ all_tests() -> publish_and_restart, subscribe_should_fail_when_global_qos_true, dead_letter_to_classic_queue, + dead_letter_with_memory_limit, dead_letter_to_quorum_queue, dead_letter_from_classic_to_quorum_queue, dead_letter_policy, @@ -774,6 +775,21 @@ dead_letter_to_classic_queue(Config) -> ?assertEqual({'queue.declare_ok', CQ, 0, 0}, declare(Ch, CQ, [])), test_dead_lettering(true, Config, Ch, Servers, ra_name(QQ), QQ, CQ). +dead_letter_with_memory_limit(Config) -> + [Server | _] = Servers = rabbit_ct_broker_helpers:get_node_configs(Config, nodename), + + Ch = rabbit_ct_client_helpers:open_channel(Config, Server), + QQ = ?config(queue_name, Config), + CQ = <<"classic-dead_letter_with_memory_limit">>, + ?assertEqual({'queue.declare_ok', QQ, 0, 0}, + declare(Ch, QQ, [{<<"x-queue-type">>, longstr, <<"quorum">>}, + {<<"x-max-in-memory-length">>, long, 0}, + {<<"x-dead-letter-exchange">>, longstr, <<>>}, + {<<"x-dead-letter-routing-key">>, longstr, CQ} + ])), + ?assertEqual({'queue.declare_ok', CQ, 0, 0}, declare(Ch, CQ, [])), + test_dead_lettering(true, Config, Ch, Servers, ra_name(QQ), QQ, CQ). + test_dead_lettering(PolicySet, Config, Ch, Servers, RaName, Source, Destination) -> publish(Ch, Source), wait_for_messages_ready(Servers, RaName, 1), |