summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorZuul <zuul@review.opendev.org>2021-01-06 18:30:08 +0000
committerGerrit Code Review <review@openstack.org>2021-01-06 18:30:08 +0000
commit7f823b406ea289101694e920c724b63f35b4fe64 (patch)
tree68140692735e52dfafae56ba43beb4fb9cd7cb4b
parent686a8b61826d9bed0a989e645a13c708c3e6343c (diff)
parentb8f8b17030e93f6fe64e986ebae1de4011f007d5 (diff)
downloadoslo-messaging-7f823b406ea289101694e920c724b63f35b4fe64.tar.gz
Merge "Fix type of direct_mandatory_flag opt"
-rw-r--r--oslo_messaging/_drivers/impl_rabbit.py12
1 files changed, 6 insertions, 6 deletions
diff --git a/oslo_messaging/_drivers/impl_rabbit.py b/oslo_messaging/_drivers/impl_rabbit.py
index f436cbe..756641b 100644
--- a/oslo_messaging/_drivers/impl_rabbit.py
+++ b/oslo_messaging/_drivers/impl_rabbit.py
@@ -169,12 +169,12 @@ rabbit_opts = [
default=2,
help='How often times during the heartbeat_timeout_threshold '
'we check the heartbeat.'),
- cfg.IntOpt('direct_mandatory_flag',
- default=True,
- help='Enable/Disable the RabbitMQ mandatory flag '
- 'for direct send. The direct send is used as reply, '
- 'so the MessageUndeliverable exception is raised '
- 'in case the client queue does not exist.'),
+ cfg.BoolOpt('direct_mandatory_flag',
+ default=True,
+ help='Enable/Disable the RabbitMQ mandatory flag '
+ 'for direct send. The direct send is used as reply, '
+ 'so the MessageUndeliverable exception is raised '
+ 'in case the client queue does not exist.'),
cfg.BoolOpt('enable_cancel_on_failover',
default=False,
help="Enable x-cancel-on-ha-failover flag so that "