modules/rabbitmq/lib/puppet/provider/rabbitmq_plugin/rabbitmqplugins.rb

   1 Puppet::Type.type(:rabbitmq_plugin).provide(:rabbitmqplugins) do
   2
   3   commands :rabbitmqplugins => '/usr/lib/rabbitmq/bin/rabbitmq-plugins'
   4   defaultfor :feature => :posix
   5
   6   def self.instances
   7     rabbitmqplugins('list', '-E').split(/\n/).map do |line|
   8       if line.split(/\s+/)[1] =~ /^(\S+)$/
   9         new(:name => $1)
  10       else
  11         raise Puppet::Error, "Cannot parse invalid plugins line: #{line}"
  12       end
  13     end
  14   end
  15
  16   def create
  17     rabbitmqplugins('enable', resource[:name])
  18   end
  19
  20   def destroy
  21     rabbitmqplugins('disable', resource[:name])
  22   end
  23
  24   def exists?
  25     out = rabbitmqplugins('list', '-E').split(/\n/).detect do |line|
  26       line.split(/\s+/)[1].match(/^#{resource[:name]}$/)
  27     end
  28   end
  29
  30 end