diff --git a/manifests/init.pp b/manifests/init.pp index f9e3c60a..e25cc62a 100644 --- a/manifests/init.pp +++ b/manifests/init.pp @@ -79,6 +79,14 @@ # (Optional) Limit the number of memory bytes used by the quorum queue. # Defaults to $facts['os_service_default'] # +# [*rabbit_use_queue_manager*] +# (Optional) Should we use consistant queue names or random ones. +# Defaults to $facts['os_service_default'] +# +# [*rabbit_stream_fanout*] +# (Optional) Use stream queues in RabbitMQ (x-queue-type: stream). +# Defaults to $facts['os_service_default'] +# # [*rabbit_enable_cancel_on_failover*] # (Optional) Enable x-cancel-on-ha-failover flag so that rabbitmq server will # cancel and notify consumers when queue is down. @@ -203,6 +211,8 @@ class barbican( $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'], + $rabbit_use_queue_manager = $facts['os_service_default'], + $rabbit_stream_fanout = $facts['os_service_default'], $rabbit_enable_cancel_on_failover = $facts['os_service_default'], $amqp_durable_queues = $facts['os_service_default'], $amqp_auto_delete = $facts['os_service_default'], @@ -258,6 +268,8 @@ class barbican( rabbit_quorum_delivery_limit => $rabbit_quorum_delivery_limit, rabbit_quorum_max_memory_length => $rabbit_quorum_max_memory_length, rabbit_quorum_max_memory_bytes => $rabbit_quorum_max_memory_bytes, + use_queue_manager => $rabbit_use_queue_manager, + rabbit_stream_fanout => $rabbit_stream_fanout, enable_cancel_on_failover => $rabbit_enable_cancel_on_failover, } diff --git a/releasenotes/notes/queue_manager-and-stream_fanout-d4ca0257fa258834.yaml b/releasenotes/notes/queue_manager-and-stream_fanout-d4ca0257fa258834.yaml new file mode 100644 index 00000000..fb439f69 --- /dev/null +++ b/releasenotes/notes/queue_manager-and-stream_fanout-d4ca0257fa258834.yaml @@ -0,0 +1,5 @@ +--- +features: + - | + The ``barbican`` class now has two new parameters + ``rabbit_use_queue_manager`` and ``rabbit_stream_fanout``. diff --git a/spec/classes/barbican_init_spec.rb b/spec/classes/barbican_init_spec.rb index 506315a6..8cb97049 100644 --- a/spec/classes/barbican_init_spec.rb +++ b/spec/classes/barbican_init_spec.rb @@ -94,6 +94,8 @@ describe 'barbican' do :rabbit_quorum_delivery_limit => 3, :rabbit_quorum_max_memory_length => 5, :rabbit_quorum_max_memory_bytes => 1073741824, + :rabbit_use_queue_manager => true, + :rabbit_stream_fanout => true, :rabbit_enable_cancel_on_failover => false, :amqp_durable_queues => true, :amqp_auto_delete => true, @@ -154,6 +156,8 @@ describe 'barbican' do :rabbit_quorum_delivery_limit => params[:rabbit_quorum_delivery_limit], :rabbit_quorum_max_memory_length => params[:rabbit_quorum_max_memory_length], :rabbit_quorum_max_memory_bytes => params[:rabbit_quorum_max_memory_bytes], + :use_queue_manager => params[:rabbit_use_queue_manager], + :rabbit_stream_fanout => params[:rabbit_stream_fanout], :enable_cancel_on_failover => params[:rabbit_enable_cancel_on_failover], ) end