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