Puppet::Type.newtype(:rabbitmq_queue) do
- desc <<-DESC
-Native type for managing rabbitmq queue
-
-@example Create a rabbitmq_queue
- rabbitmq_queue { 'myqueue@myvhost':
- ensure => present,
- user => 'dan',
- password => 'bar',
- durable => true,
- auto_delete => false,
- arguments => {
- x-message-ttl => 123,
- x-dead-letter-exchange => 'other'
- },
- }
-DESC
+ desc 'Native type for managing rabbitmq queue'
ensurable do
defaultto(:present)
end
end
- newparam(:name, namevar: true) do
+ newparam(:name, :namevar => true) do
desc 'Name of queue'
- newvalues(%r{^\S*@\S+$})
+ newvalues(/^\S*@\S+$/)
end
newparam(:durable) do
desc 'Queue is durable'
- newvalues(%r{true|false})
+ newvalues(/true|false/)
defaultto('true')
end
-
+
newparam(:auto_delete) do
desc 'Queue will be auto deleted'
- newvalues(%r{true|false})
+ newvalues(/true|false/)
defaultto('false')
end
newparam(:user) do
desc 'The user to use to connect to rabbitmq'
defaultto('guest')
- newvalues(%r{^\S+$})
+ newvalues(/^\S+$/)
end
newparam(:password) do
desc 'The password to use to connect to rabbitmq'
defaultto('guest')
- newvalues(%r{\S+})
+ newvalues(/\S+/)
end
autorequire(:rabbitmq_vhost) do
end
def validate_argument(argument)
- raise ArgumentError, 'Invalid argument' unless [Hash].include?(argument.class)
+ unless [Hash].include?(argument.class)
+ raise ArgumentError, "Invalid argument"
+ end
end
end