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/amqqueue.hrl | |
| 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/amqqueue.hrl')
| -rw-r--r-- | include/amqqueue.hrl | 6 |
1 files changed, 3 insertions, 3 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), |