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 /include | |
| 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 'include')
| -rw-r--r-- | include/amqqueue.hrl | 6 | ||||
| -rw-r--r-- | include/amqqueue_v2.hrl | 2 |
2 files changed, 4 insertions, 4 deletions
diff --git a/include/amqqueue.hrl b/include/amqqueue.hrl index 3a9ac45cce..5a8a9bad03 100644 --- a/include/amqqueue.hrl +++ b/include/amqqueue.hrl @@ -51,16 +51,16 @@ (?is_amqqueue_v1(Q) andalso ?amqqueue_v1_field_state(Q) =:= State))). --define(amqqueue_v1_type, classic). +-define(amqqueue_v1_type, rabbit_classic_queue). -define(amqqueue_is_classic(Q), ((?is_amqqueue_v2(Q) andalso - ?amqqueue_v2_field_type(Q) =:= classic) orelse + ?amqqueue_v2_field_type(Q) =:= rabbit_classic_queue) orelse ?is_amqqueue_v1(Q))). -define(amqqueue_is_quorum(Q), (?is_amqqueue_v2(Q) andalso - ?amqqueue_v2_field_type(Q) =:= quorum) orelse + ?amqqueue_v2_field_type(Q) =:= rabbit_quorum_queue) orelse false). -define(amqqueue_has_valid_pid(Q), diff --git a/include/amqqueue_v2.hrl b/include/amqqueue_v2.hrl index 37cd7ba2a8..c79a3b7366 100644 --- a/include/amqqueue_v2.hrl +++ b/include/amqqueue_v2.hrl @@ -19,4 +19,4 @@ -define(amqqueue_v2_field_vhost(Q), element(18, Q)). -define(amqqueue_v2_field_options(Q), element(19, Q)). -define(amqqueue_v2_field_type(Q), element(20, Q)). --define(amqqueue_v2_field_quorum_nodes(Q), element(21, Q)). +-define(amqqueue_v2_field_type_state(Q), element(21, Q)). |