class Sonic::Protocol::AMQP

Public Class Methods

new(service_checker) click to toggle source
# File lib/sonic/protocols/amqp.rb, line 8
def initialize(service_checker)
  @service_checker = service_checker
end

Public Instance Methods

check() click to toggle source
# File lib/sonic/protocols/amqp.rb, line 12
def check
  begin
    conn = ::Bunny.new(:host => @service_checker.host,
                       :port => @service_checker.port,
                       :username => @service_checker.username,
                       :password => @service_checker.password,
                       :vhost => @service_checker.vhost)
    conn.start
    @service_checker.response = conn.status
    if @service_checker.response == :open
      true
    else
      @service_checker.error = "service error"
      false
    end
    conn.close
  rescue Exception => e
    @service_checker.error = e.to_s
    false
  end
end