122 lines
4.1 KiB
Puppet
122 lines
4.1 KiB
Puppet
class rabbitmq::config {
|
|
|
|
$cluster_disk_nodes = $rabbitmq::cluster_disk_nodes
|
|
$cluster_node_type = $rabbitmq::cluster_node_type
|
|
$cluster_nodes = $rabbitmq::cluster_nodes
|
|
$config = $rabbitmq::config
|
|
$config_cluster = $rabbitmq::config_cluster
|
|
$config_path = $rabbitmq::config_path
|
|
$config_stomp = $rabbitmq::config_stomp
|
|
$default_user = $rabbitmq::default_user
|
|
$default_pass = $rabbitmq::default_pass
|
|
$env_config = $rabbitmq::env_config
|
|
$env_config_path = $rabbitmq::env_config_path
|
|
$erlang_cookie = $rabbitmq::erlang_cookie
|
|
$node_ip_address = $rabbitmq::node_ip_address
|
|
$plugin_dir = $rabbitmq::plugin_dir
|
|
$port = $rabbitmq::port
|
|
$service_name = $rabbitmq::service_name
|
|
$ssl = $rabbitmq::ssl
|
|
$ssl_only = $rabbitmq::ssl_only
|
|
$ssl_cacert = $rabbitmq::ssl_cacert
|
|
$ssl_cert = $rabbitmq::ssl_cert
|
|
$ssl_key = $rabbitmq::ssl_key
|
|
$ssl_management_port = $rabbitmq::ssl_management_port
|
|
$ssl_stomp_port = $rabbitmq::ssl_stomp_port
|
|
$ssl_verify = $rabbitmq::ssl_verify
|
|
$ssl_fail_if_no_peer_cert = $rabbitmq::ssl_fail_if_no_peer_cert
|
|
$stomp_port = $rabbitmq::stomp_port
|
|
$wipe_db_on_cookie_change = $rabbitmq::wipe_db_on_cookie_change
|
|
$config_variables = $rabbitmq::config_variables
|
|
$config_kernel_variables = $rabbitmq::config_kernel_variables
|
|
$cluster_partition_handling = $rabbitmq::cluster_partition_handling
|
|
$default_env_variables = {
|
|
'RABBITMQ_NODE_PORT' => $port,
|
|
'RABBITMQ_NODE_IP_ADDRESS' => $node_ip_address
|
|
}
|
|
|
|
# Handle env variables.
|
|
$environment_variables = merge($default_env_variables, $rabbitmq::environment_variables)
|
|
|
|
# Handle deprecated option.
|
|
if $cluster_disk_nodes != [] {
|
|
notify { 'cluster_disk_nodes':
|
|
message => 'WARNING: The cluster_disk_nodes is deprecated.
|
|
Use cluster_nodes instead.',
|
|
}
|
|
$r_cluster_nodes = $cluster_disk_nodes
|
|
} else {
|
|
$r_cluster_nodes = $cluster_nodes
|
|
}
|
|
|
|
file { '/etc/rabbitmq':
|
|
ensure => directory,
|
|
owner => '0',
|
|
group => '0',
|
|
mode => '0644',
|
|
}
|
|
|
|
file { '/etc/rabbitmq/ssl':
|
|
ensure => directory,
|
|
owner => '0',
|
|
group => '0',
|
|
mode => '0644',
|
|
}
|
|
|
|
file { 'rabbitmq.config':
|
|
ensure => file,
|
|
path => $config_path,
|
|
content => template($config),
|
|
owner => '0',
|
|
group => '0',
|
|
mode => '0644',
|
|
notify => Class['rabbitmq::service'],
|
|
}
|
|
|
|
file { 'rabbitmq-env.config':
|
|
ensure => file,
|
|
path => $env_config_path,
|
|
content => template($env_config),
|
|
owner => '0',
|
|
group => '0',
|
|
mode => '0644',
|
|
notify => Class['rabbitmq::service'],
|
|
}
|
|
|
|
|
|
if $config_cluster {
|
|
|
|
file { 'erlang_cookie':
|
|
ensure => 'present',
|
|
path => '/var/lib/rabbitmq/.erlang.cookie',
|
|
owner => 'rabbitmq',
|
|
group => 'rabbitmq',
|
|
mode => '0400',
|
|
content => $erlang_cookie,
|
|
replace => true,
|
|
before => File['rabbitmq.config'],
|
|
notify => Class['rabbitmq::service'],
|
|
}
|
|
|
|
# rabbitmq_erlang_cookie is a fact in this module.
|
|
if $erlang_cookie != $::rabbitmq_erlang_cookie {
|
|
# Safety check.
|
|
if $wipe_db_on_cookie_change {
|
|
exec { 'wipe_db':
|
|
command => "puppet resource service ${service_name} ensure=stopped; rm -rf /var/lib/rabbitmq/mnesia",
|
|
path => '/bin:/sbin:/usr/bin:/usr/sbin:/usr/local/bin:/usr/local/sbin',
|
|
}
|
|
File['erlang_cookie'] {
|
|
require => Exec['wipe_db'],
|
|
}
|
|
} else {
|
|
fail("ERROR: The current erlang cookie is ${::rabbitmq_erlang_cookie} and needs to change to ${erlang_cookie}. In order to do this the RabbitMQ database needs to be wiped. Please set the parameter called wipe_db_on_cookie_change to true to allow this to happen automatically.")
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
|
|
}
|
|
|