diff options
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)). |