diff options
Diffstat (limited to 'include/amqqueue.hrl')
| -rw-r--r-- | include/amqqueue.hrl | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/include/amqqueue.hrl b/include/amqqueue.hrl index 48ffd3da77..097f1dfa0c 100644 --- a/include/amqqueue.hrl +++ b/include/amqqueue.hrl @@ -54,6 +54,11 @@ ?amqqueue_v2_field_type(Q) =:= rabbit_quorum_queue) orelse false). +-define(amqqueue_is_stream(Q), + (?is_amqqueue_v2(Q) andalso + ?amqqueue_v2_field_type(Q) =:= rabbit_stream_queue) orelse + false). + -define(amqqueue_has_valid_pid(Q), ((?is_amqqueue_v2(Q) andalso is_pid(?amqqueue_v2_field_pid(Q))) orelse |