Contents

default[:api_url] = 'http://admin:admin@127.0.0.1:55672/api'
default[:vhost] = ['notexists']

collect do
  plugin.vhosts.each do |vhost|
    vhost_uri = "#{plugin.api_url}/queues/#{CGI.escape(vhost)}"
    JSON.parse(rest_get(vhost_uri)).each do |queue|
      event(
          :service => "rabbitmq queue #{queue['name'].gsub('.', '_')} messages count",
          :metric => queue['messages'].to_i,
          :desc => "Rabbitmq queue count in #{queue['name']}",
          :critical => 1000
      )
    end
  end
end

Version data entries

51 entries across 51 versions & 1 rubygems

Version	Path
kurchatov-0.4.7	examples/rabbitmq.rb
kurchatov-0.4.6	examples/rabbitmq.rb
kurchatov-0.4.5	examples/rabbitmq.rb
kurchatov-0.4.4	examples/rabbitmq.rb
kurchatov-0.4.3	examples/rabbitmq.rb
kurchatov-0.4.2	examples/rabbitmq.rb
kurchatov-0.4.1	examples/rabbitmq.rb
kurchatov-0.3.8	examples/rabbitmq.rb
kurchatov-0.3.7	examples/rabbitmq.rb
kurchatov-0.3.6	examples/rabbitmq.rb
kurchatov-0.3.5	examples/rabbitmq.rb
kurchatov-0.3.4	examples/rabbitmq.rb
kurchatov-0.3.3	examples/rabbitmq.rb
kurchatov-0.3.2	examples/rabbitmq.rb
kurchatov-0.3.1	examples/rabbitmq.rb
kurchatov-0.3.0	examples/rabbitmq.rb
kurchatov-0.2.9	examples/rabbitmq.rb
kurchatov-0.2.8	examples/rabbitmq.rb
kurchatov-0.2.7	examples/rabbitmq.rb
kurchatov-0.2.6	examples/rabbitmq.rb