diff options
| author | kjnilsson <knilsson@pivotal.io> | 2019-07-02 16:11:54 +0100 |
|---|---|---|
| committer | kjnilsson <knilsson@pivotal.io> | 2019-08-07 16:09:29 +0100 |
| commit | 344492576f6ff3bbd947b1d3b60f7cf01c367cd2 (patch) | |
| tree | 11eddddf0b730e333e700f46966cace5588436e8 /test | |
| parent | e59dcbe3f4945ca19ae580acae6422ae7adc39a4 (diff) | |
| download | rabbitmq-server-git-344492576f6ff3bbd947b1d3b60f7cf01c367cd2.tar.gz | |
Add marker rabbit_queue_type behaviour
And use the implementing module as the value of the amqqueue record
`type` field. This will allow for easy dispatch to the queue type
implementation.
Make amqqueue compatible with the classic queue tag
Diffstat (limited to 'test')
| -rw-r--r-- | test/amqqueue_backward_compatibility_SUITE.erl | 6 | ||||
| -rw-r--r-- | test/quorum_queue_SUITE.erl | 6 |
2 files changed, 6 insertions, 6 deletions
diff --git a/test/amqqueue_backward_compatibility_SUITE.erl b/test/amqqueue_backward_compatibility_SUITE.erl index 05a049c9bb..a02c4721bc 100644 --- a/test/amqqueue_backward_compatibility_SUITE.erl +++ b/test/amqqueue_backward_compatibility_SUITE.erl @@ -104,7 +104,7 @@ new_amqqueue_v2_is_amqqueue(_) -> [], VHost, #{}, - classic), + rabbit_classic_queue), ?assert(?is_amqqueue(Queue)), ?assert(?is_amqqueue_v2(Queue)), ?assert(not ?is_amqqueue_v1(Queue)), @@ -253,7 +253,7 @@ amqqueue_v2_type_matching(_) -> [], VHost, #{}, - classic), + rabbit_classic_queue), ?assert(?amqqueue_is_classic(ClassicQueue)), ?assert(amqqueue:is_classic(ClassicQueue)), ?assert(not ?amqqueue_is_quorum(ClassicQueue)), @@ -267,7 +267,7 @@ amqqueue_v2_type_matching(_) -> [], VHost, #{}, - quorum), + rabbit_quorum_queue), ?assert(not ?amqqueue_is_classic(QuorumQueue)), ?assert(not amqqueue:is_classic(QuorumQueue)), ?assert(?amqqueue_is_quorum(QuorumQueue)), diff --git a/test/quorum_queue_SUITE.erl b/test/quorum_queue_SUITE.erl index cc0e7aa75a..7ef38895eb 100644 --- a/test/quorum_queue_SUITE.erl +++ b/test/quorum_queue_SUITE.erl @@ -264,15 +264,15 @@ declare_args(Config) -> declare(Ch, LQ, [{<<"x-queue-type">>, longstr, <<"quorum">>}, {<<"x-max-length">>, long, 2000}, {<<"x-max-length-bytes">>, long, 2000}]), - assert_queue_type(Server, LQ, quorum), + assert_queue_type(Server, LQ, rabbit_quorum_queue), DQ = <<"classic-declare-args-q">>, declare(Ch, DQ, [{<<"x-queue-type">>, longstr, <<"classic">>}]), - assert_queue_type(Server, DQ, classic), + assert_queue_type(Server, DQ, rabbit_classic_queue), DQ2 = <<"classic-q2">>, declare(Ch, DQ2), - assert_queue_type(Server, DQ2, classic). + assert_queue_type(Server, DQ2, rabbit_classic_queue). declare_invalid_properties(Config) -> Server = rabbit_ct_broker_helpers:get_node_config(Config, 0, nodename), |