diff options
| author | Karl Nilsson <kjnilsson@gmail.com> | 2020-09-30 16:32:23 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-09-30 16:32:23 +0100 |
| commit | 5cd95d69d8f28fc08fa919c0b9f62689f2594f93 (patch) | |
| tree | a0656e0fc7da62d1f648cb993b57249b02b2ef8c /include/amqqueue.hrl | |
| parent | bdb6f9b508dd1aaad5e618d9a620adb7972e618f (diff) | |
| parent | 6d6e4dd76ccbe95ac445fd581a6bb6de631929cd (diff) | |
| download | rabbitmq-server-git-5cd95d69d8f28fc08fa919c0b9f62689f2594f93.tar.gz | |
Merge pull request #2347 from rabbitmq/stream-queue
Stream queue
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 |