Merge pull request voxpupuli#1 from carlf/add_mqtt

First pass at adding mqtt support

Author: Carl Flippin

manifests/init.pp

@@ -5,6 +5,7 @@
   $cluster_nodes              = $rabbitmq::params::cluster_nodes,
   $config                     = $rabbitmq::params::config,
   $config_cluster             = $rabbitmq::params::config_cluster,
+  $config_mqtt                = $rabbitmq::params::config_mqtt,
   $config_path                = $rabbitmq::params::config_path,
   $config_stomp               = $rabbitmq::params::config_stomp,
   $default_user               = $rabbitmq::params::default_user,
@@ -24,6 +25,8 @@
   $package_source             = undef,
   $repos_ensure               = $rabbitmq::params::repos_ensure,
   $manage_repos               = $rabbitmq::params::manage_repos,
+  $mqtt_ensure                = $rabbitmq::params::mqtt_ensure,
+  $mqtt_port                  = $rabbitmq::params::mqtt_port,
   $plugin_dir                 = $rabbitmq::params::plugin_dir,
   $rabbitmq_user              = $rabbitmq::params::rabbitmq_user,
   $rabbitmq_group             = $rabbitmq::params::rabbitmq_group,
@@ -41,6 +44,7 @@
   $ssl_port                   = $rabbitmq::params::ssl_port,
   $ssl_interface              = $rabbitmq::params::ssl_interface,
   $ssl_management_port        = $rabbitmq::params::ssl_management_port,
+  $ssl_mqtt_port              = $rabbitmq::params::ssl_mqtt_port,
   $ssl_stomp_port             = $rabbitmq::params::ssl_stomp_port,
   $ssl_verify                 = $rabbitmq::params::ssl_verify,
   $ssl_fail_if_no_peer_cert   = $rabbitmq::params::ssl_fail_if_no_peer_cert,
@@ -82,6 +86,8 @@
   validate_absolute_path($config_path)
   validate_bool($config_cluster)
   validate_bool($config_stomp)
+  validate_bool($config_mqtt)
+  validate_bool($mqtt_ensure)
   validate_string($default_user)
   validate_string($default_pass)
   validate_bool($delete_guest_user)
@@ -96,6 +102,9 @@
   if ! is_integer($port) {
     validate_re($port, ['\d+','UNSET'])
   }
+  if ! is_integer($mqtt_port) {
+    validate_re($mqtt_port, '\d+')
+  }
   if ! is_integer($stomp_port) {
     validate_re($stomp_port, '\d+')
   }
@@ -120,6 +129,9 @@
   if ! is_integer($ssl_management_port) {
     validate_re($ssl_management_port, '\d+')
   }
+  if ! is_integer($ssl_mqtt_port) {
+    validate_re($ssl_mqtt_port, '\d+')
+  }
   if ! is_integer($ssl_stomp_port) {
     validate_re($ssl_stomp_port, '\d+')
   }
@@ -217,6 +229,14 @@
     }
   }
 
+  if $mqtt_ensure {
+    rabbitmq_plugin { 'rabbitmq_mqtt':
+      ensure  => present,
+      require => Class['rabbitmq::install'],
+      notify  => Class['rabbitmq::service'],
+    }
+  }
+
   if ($ldap_auth) {
     rabbitmq_plugin { 'rabbitmq_auth_backend_ldap':
       ensure  => present,

manifests/params.pp

@@ -77,6 +77,7 @@
   $cluster_nodes              = []
   $config                     = 'rabbitmq/rabbitmq.config.erb'
   $config_cluster             = false
+  $config_mqtt                = false
   $config_path                = '/etc/rabbitmq/rabbitmq.config'
   $config_stomp               = false
   $default_user               = 'guest'
@@ -86,6 +87,8 @@
   $env_config_path            = '/etc/rabbitmq/rabbitmq-env.conf'
   $erlang_cookie              = undef
   $interface                  = 'UNSET'
+  $mqtt_ensure                = false
+  $mqtt_port                  = '1883'
   $node_ip_address            = 'UNSET'
   $port                       = '5672'
   $tcp_keepalive              = false
@@ -97,6 +100,7 @@
   $ssl_port                   = '5671'
   $ssl_interface              = 'UNSET'
   $ssl_management_port        = '15671'
+  $ssl_mqtt_port              = '8883'
   $ssl_stomp_port             = '6164'
   $ssl_verify                 = 'verify_none'
   $ssl_fail_if_no_peer_cert   = false

templates/rabbitmq.config.erb

@@ -90,6 +90,14 @@
   <%- end -%>
   ]}
 <% end -%>
+<% if @config_mqtt -%>,
+  {rabbitmq_mqtt, [
+    {tcp_listeners, [<%= @mqtt_port %>]}
+  <%- if @ssl && @ssl_mqtt_port -%>,
+    {ssl_listeners, [<%= @ssl_mqtt_port %>]}
+  <%- end -%>
+  ]}
+<% end -%>
 <%- if @ldap_auth -%>,
 % Configure the LDAP authentication plugin
   {rabbitmq_auth_backend_ldap, [