From ede60d7a83b0f7393b450270ce6cbbe3c13f210f Mon Sep 17 00:00:00 2001 From: frankming Date: Thu, 21 Mar 2024 15:53:56 +0800 Subject: [PATCH] Fix incorrect desc of rabbit_stream_fanout option 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 --- oslo_messaging/_drivers/impl_rabbit.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/oslo_messaging/_drivers/impl_rabbit.py b/oslo_messaging/_drivers/impl_rabbit.py index 74a8ee187..fa9a68faf 100644 --- a/oslo_messaging/_drivers/impl_rabbit.py +++ b/oslo_messaging/_drivers/impl_rabbit.py @@ -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__)