Implement variables to address oslo.messaging improvements

During last release cycle oslo.messaging has landed [1] series of extremely
useful changes that are designed to implement modern messaging
techniques for rabbitmq quorum queues.

Since these changes are breaking and require queues being re-created,
it makes total sense to align these with migration to quorum queues by default.

[1] https://review.opendev.org/q/topic:%22bug-2031497%22

Change-Id: I7d439d03086ef65e3533d87cf1dc5c0237c8eeb0
This commit is contained in:
Dmitriy Rabotyagov 2024-05-10 16:47:56 +02:00
parent 5a692ce993
commit 72059c1cfb
2 changed files with 8 additions and 0 deletions

View File

@ -103,6 +103,10 @@ tacker_oslomsg_notify_policies: []
## RabbitMQ integration ## RabbitMQ integration
tacker_oslomsg_rabbit_quorum_queues: "{{ oslomsg_rabbit_quorum_queues | default(True) }}" tacker_oslomsg_rabbit_quorum_queues: "{{ oslomsg_rabbit_quorum_queues | default(True) }}"
tacker_oslomsg_rabbit_stream_fanout: "{{ oslomsg_rabbit_stream_fanout | default(tacker_oslomsg_rabbit_quorum_queues) }}"
tacker_oslomsg_rabbit_transient_quorum_queues: "{{ oslomsg_rabbit_transient_quorum_queues | default(tacker_oslomsg_rabbit_stream_fanout) }}"
tacker_oslomsg_rabbit_qos_prefetch_count: "{{ oslomsg_rabbit_qos_prefetch_count | default(tacker_oslomsg_rabbit_stream_fanout | ternary(10, 0)) }}"
tacker_oslomsg_rabbit_queue_manager: "{{ oslomsg_rabbit_queue_manager | default(tacker_oslomsg_rabbit_quorum_queues) }}"
tacker_oslomsg_rabbit_quorum_delivery_limit: "{{ oslomsg_rabbit_quorum_delivery_limit | default(0) }}" tacker_oslomsg_rabbit_quorum_delivery_limit: "{{ oslomsg_rabbit_quorum_delivery_limit | default(0) }}"
tacker_oslomsg_rabbit_quorum_max_memory_bytes: "{{ oslomsg_rabbit_quorum_max_memory_bytes | default(0) }}" tacker_oslomsg_rabbit_quorum_max_memory_bytes: "{{ oslomsg_rabbit_quorum_max_memory_bytes | default(0) }}"

View File

@ -97,6 +97,10 @@ openstack = {{ tacker_etc_dir }}/vim/fernet_keys
[oslo_messaging_rabbit] [oslo_messaging_rabbit]
ssl = {{ tacker_oslomsg_notify_use_ssl | bool }} ssl = {{ tacker_oslomsg_notify_use_ssl | bool }}
rabbit_quorum_queue = {{ tacker_oslomsg_rabbit_quorum_queues }} rabbit_quorum_queue = {{ tacker_oslomsg_rabbit_quorum_queues }}
rabbit_transient_quorum_queue = {{ tacker_oslomsg_rabbit_transient_quorum_queues }}
rabbit_qos_prefetch_count = {{ tacker_oslomsg_rabbit_qos_prefetch_count }}
use_queue_manager = {{ tacker_oslomsg_rabbit_queue_manager }}
rabbit_stream_fanout = {{ tacker_oslomsg_rabbit_stream_fanout }}
rabbit_quorum_delivery_limit = {{ tacker_oslomsg_rabbit_quorum_delivery_limit }} rabbit_quorum_delivery_limit = {{ tacker_oslomsg_rabbit_quorum_delivery_limit }}
rabbit_quorum_max_memory_bytes = {{ tacker_oslomsg_rabbit_quorum_max_memory_bytes }} rabbit_quorum_max_memory_bytes = {{ tacker_oslomsg_rabbit_quorum_max_memory_bytes }}