diff --git a/manifests/messaging/rabbit.pp b/manifests/messaging/rabbit.pp index 9b2d82a..605a64d 100644 --- a/manifests/messaging/rabbit.pp +++ b/manifests/messaging/rabbit.pp @@ -117,6 +117,10 @@ # (Optional) Use quorum queues in RabbitMQ. # Defaults to $facts['os_service_default'] # +# [*rabbit_transient_quorum_queue*] +# (Optional) Use quorum queues for transients queues in RabbitMQ. +# Defaults to $facts['os_service_default'] +# # [*rabbit_quorum_delivery_limit*] # (Optional) Each time a message is rdelivered to a consumer, a counter is # incremented. Once the redelivery count exceeds the delivery limit @@ -153,6 +157,7 @@ define oslo::messaging::rabbit( $heartbeat_rate = $facts['os_service_default'], $heartbeat_in_pthread = $facts['os_service_default'], $rabbit_quorum_queue = $facts['os_service_default'], + $rabbit_transient_quorum_queue = $facts['os_service_default'], $rabbit_quorum_delivery_limit = $facts['os_service_default'], $rabbit_quorum_max_memory_length = $facts['os_service_default'], $rabbit_quorum_max_memory_bytes = $facts['os_service_default'], @@ -204,6 +209,7 @@ define oslo::messaging::rabbit( 'oslo_messaging_rabbit/rabbit_qos_prefetch_count' => { value => $rabbit_qos_prefetch_count }, 'oslo_messaging_rabbit/rabbit_ha_queues' => { value => $rabbit_ha_queues }, 'oslo_messaging_rabbit/rabbit_quorum_queue' => { value => $rabbit_quorum_queue }, + 'oslo_messaging_rabbit/rabbit_transient_quorum_queue' => { value => $rabbit_transient_quorum_queue }, 'oslo_messaging_rabbit/rabbit_quorum_delivery_limit' => { value => $rabbit_quorum_delivery_limit }, 'oslo_messaging_rabbit/rabbit_quorum_max_memory_length' => { value => $rabbit_quorum_max_memory_length }, 'oslo_messaging_rabbit/rabbit_quorum_max_memory_bytes' => { value => $rabbit_quorum_max_memory_bytes }, diff --git a/releasenotes/notes/rabbit_transient_quorum_queue-dc8393c75feb5046.yaml b/releasenotes/notes/rabbit_transient_quorum_queue-dc8393c75feb5046.yaml new file mode 100644 index 0000000..5ef615b --- /dev/null +++ b/releasenotes/notes/rabbit_transient_quorum_queue-dc8393c75feb5046.yaml @@ -0,0 +1,5 @@ +--- +features: + - | + The new ``oslo::messaging::rabbit::rabbit_transient_quorum_queue`` + parameter has been added. diff --git a/spec/defines/oslo_messaging_rabbit_spec.rb b/spec/defines/oslo_messaging_rabbit_spec.rb index 6736052..5245287 100644 --- a/spec/defines/oslo_messaging_rabbit_spec.rb +++ b/spec/defines/oslo_messaging_rabbit_spec.rb @@ -25,6 +25,7 @@ describe 'oslo::messaging::rabbit' do is_expected.to contain_keystone_config('oslo_messaging_rabbit/heartbeat_rate').with_value('') is_expected.to contain_keystone_config('oslo_messaging_rabbit/heartbeat_in_pthread').with_value('') is_expected.to contain_keystone_config('oslo_messaging_rabbit/rabbit_quorum_queue').with_value('') + is_expected.to contain_keystone_config('oslo_messaging_rabbit/rabbit_transient_quorum_queue').with_value('') is_expected.to contain_keystone_config('oslo_messaging_rabbit/rabbit_quorum_delivery_limit').with_value('') is_expected.to contain_keystone_config('oslo_messaging_rabbit/rabbit_quorum_max_memory_length').with_value('') is_expected.to contain_keystone_config('oslo_messaging_rabbit/rabbit_quorum_max_memory_bytes').with_value('') @@ -41,6 +42,7 @@ describe 'oslo::messaging::rabbit' do :kombu_compression => 'bz2', :rabbit_ha_queues => true, :rabbit_quorum_queue => true, + :rabbit_transient_quorum_queue => true, :rabbit_quorum_delivery_limit => 3, :rabbit_quorum_max_memory_length => 5, :rabbit_quorum_max_memory_bytes => 1073741824, @@ -55,6 +57,7 @@ describe 'oslo::messaging::rabbit' do is_expected.to contain_keystone_config('oslo_messaging_rabbit/kombu_compression').with_value('bz2') is_expected.to contain_keystone_config('oslo_messaging_rabbit/rabbit_ha_queues').with_value(true) is_expected.to contain_keystone_config('oslo_messaging_rabbit/rabbit_quorum_queue').with_value(true) + is_expected.to contain_keystone_config('oslo_messaging_rabbit/rabbit_transient_quorum_queue').with_value(true) is_expected.to contain_keystone_config('oslo_messaging_rabbit/rabbit_quorum_delivery_limit').with_value(3) is_expected.to contain_keystone_config('oslo_messaging_rabbit/rabbit_quorum_max_memory_length').with_value(5) is_expected.to contain_keystone_config('oslo_messaging_rabbit/rabbit_quorum_max_memory_bytes').with_value(1073741824)