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: Id66345774cc9a2e2ffbe268ea8e6c4bd8908ee72
This commit is contained in:
Dmitriy Rabotyagov 2024-04-23 19:18:07 +02:00 committed by Dmitriy Rabotyagov
parent 5772b128a5
commit ffe8dc3a81
2 changed files with 6 additions and 0 deletions

View File

@ -143,6 +143,9 @@ glance_oslomsg_notify_policies: []
## RabbitMQ integration
glance_oslomsg_rabbit_quorum_queues: "{{ oslomsg_rabbit_quorum_queues | default(True) }}"
glance_oslomsg_rabbit_transient_quorum_queues: "{{ oslomsg_rabbit_transient_quorum_queues | default(glance_oslomsg_rabbit_quorum_queues) }}"
glance_oslomsg_rabbit_queue_manager: "{{ oslomsg_rabbit_queue_manager | default(glance_oslomsg_rabbit_quorum_queues) }}"
glance_oslomsg_rabbit_stream_fanout: "{{ oslomsg_rabbit_stream_fanout | default(glance_oslomsg_rabbit_quorum_queues) }}"
glance_oslomsg_rabbit_quorum_delivery_limit: "{{ oslomsg_rabbit_quorum_delivery_limit | default(0) }}"
glance_oslomsg_rabbit_quorum_max_memory_bytes: "{{ oslomsg_rabbit_quorum_max_memory_bytes | default(0) }}"

View File

@ -79,6 +79,9 @@ policy_dirs = {{ glance_policy_dirs }}
{% if glance_oslomsg_rpc_transport == 'rabbit' %}
[oslo_messaging_rabbit]
rabbit_quorum_queue = {{ glance_oslomsg_rabbit_quorum_queues }}
transient_quorum_queue = {{ glance_oslomsg_rabbit_transient_quorum_queues }}
use_queue_manager = {{ glance_oslomsg_rabbit_queue_manager }}
rabbit_stream_fanout = {{ glance_oslomsg_rabbit_stream_fanout }}
rabbit_quorum_delivery_limit = {{ glance_oslomsg_rabbit_quorum_delivery_limit }}
rabbit_quorum_max_memory_bytes = {{ glance_oslomsg_rabbit_quorum_max_memory_bytes }}
{% endif %}