true Mike Mangino

starling

class MissingLibrary < StandardError; end
class StarlingMonitor < Scout::Plugin

  
  attr_accessor :connection
  
  
  def setup_starling
    begin
      require 'starling'
    rescue LoadError
      begin
        require "rubygems"
        require 'starling'
      rescue LoadError
        raise MissingLibrary
      end
    end
    self.connection=Starling.new("#{option(:host)}:#{option(:port)}")
    @report = {}
  end
  
    
  
  def build_report
    begin
      setup_starling
      connection.sizeof(:all).each do |queue_name,item_count|
        check_queue(queue_name,item_count) if should_check_queue?(queue_name)
      end
      report(@report)
    rescue  MissingLibrary=>e
      error("Could not load all required libraries",
            "I failed to load the starling library. Please make sure it is installed.")
    rescue Exception=>e
      error("Got unexpected error: #{e} #{e.class}")
    end
  end

  def should_check_queue?(name)
    option(:queue_re).nil? or /#{option(:queue_re)}/ =~ name
  end
  
  def check_queue(name,depth)
    q_depth = (depth||0).to_i
    @report ||= {}
    @report[name] = q_depth
    if q_depth > option(:max_depth).to_i
      alert("Max Queue Depth for #{name} exceeded","#{q_depth} items is more than the max allowed #{option(:max_depth)}")
    end
  end

end

2008-08-08T09:42:03-07:00

Monitors the number of items in a starling queue, generating an alert if the maximum queue depth is exceeded for a given queue. false 52 --- | options: host: name: Host notes: The host to monitor default: 127.0.0.1 port: name: Port notes: The port starling is running on default: 61613 queue_re: name: Name Reqular Expresssion notes: Pattern to test against queue names to select queues to monitor default: max_depth: name: Maximum Items notes: Alert if the queue contains more items than this default: 4000 Starling Monitor

0.0

Monitor the number of items in a starling queue

Monitors the number of items in a starling queue, generating an alert if the maximum queue depth is exceeded for a given queue.

linux

2009-09-23T23:03:25-07:00

http://github.com/itsderek23/er-scout-plugins/raw/57d26e85056c6f22e6b72d37b18f799203011a36/starling_monitor/starling_monitor.rb