openstack/oslo.messaging
Code Issues Proposed changes

Fix incorrect desc of rabbit_stream_fanout option

Browse Source 
Description of rabbit_stream_fanout option is incorrect. Actually it
reuses the description of quorum queues. So we need to fix it with a
correct stream queue description.

Closes-Bug: #2058616
Change-Id: I614280c656f7d5fe9043abee93218a9907c395ff
Signed-off-by: frankming <chen27508959@outlook.com>
This commit is contained in:
frankming 2024-03-21 15:53:56 +08:00
parent 9b39870819
commit ede60d7a83
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
oslo_messaging/_drivers/impl_rabbit.py
View File

@ -254,11 +254,11 @@ rabbit_opts = [
cfg.BoolOpt('rabbit_stream_fanout',
default=False,
help='Use stream queues in RabbitMQ (x-queue-type: stream). '
'The stream queue is a modern queue type for RabbitMQ '
'implementing a durable, replicated FIFO queue based on the '
'Raft consensus algorithm. It is available as of '
'RabbitMQ 3.8.0. If set this option will replace all fanout '
'queues with only one stream queue.'),
'Streams are a new persistent and replicated data structure '
'("queue type") in RabbitMQ which models an append-only log '
'with non-destructive consumer semantics. It is available '
'as of RabbitMQ 3.9.0. If set this option will replace all '
'fanout queues with only one stream queue.'),
]
LOG = logging.getLogger(__name__)