diff options
| author | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2020-02-28 15:33:10 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-02-28 15:33:10 +0100 |
| commit | 7aa77b2f0b832fd1fd4fa08f8e0ef86a7009e1fe (patch) | |
| tree | f3035422a09194a91ba49512fed85c15463fae66 /test | |
| parent | eb061384fe508a8acaa39b75d32afd7c5a8ecee2 (diff) | |
| parent | 877c1df3098af717f043e2fc8db32aae05257873 (diff) | |
| download | rabbitmq-server-git-7aa77b2f0b832fd1fd4fa08f8e0ef86a7009e1fe.tar.gz | |
Merge pull request #2262 from rabbitmq/qq-dead-letter-bug
Fix QQ dead letter crash
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), |