diff options
| author | Karl Nilsson <kjnilsson@gmail.com> | 2019-08-07 17:48:33 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-08-07 17:48:33 +0100 |
| commit | 1984d6657531f9dbb2499a564143c6fe594fa67e (patch) | |
| tree | 11eddddf0b730e333e700f46966cace5588436e8 /include | |
| parent | e59dcbe3f4945ca19ae580acae6422ae7adc39a4 (diff) | |
| parent | 344492576f6ff3bbd947b1d3b60f7cf01c367cd2 (diff) | |
| download | rabbitmq-server-git-1984d6657531f9dbb2499a564143c6fe594fa67e.tar.gz | |
Merge pull request #2062 from rabbitmq/queue_type_scaffolding
Add marker rabbit_queue_type behaviour
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)). |