class Emque::Producing::Publisher::Base
Public Instance Methods
handle_error(e)
click to toggle source
# File lib/emque/producing/publisher/base.rb, line 9 def handle_error(e) Emque::Producing.configuration.error_handlers.each do |handler| begin handler.call(e, nil) rescue => ex Emque::Producing.logger.error "Producer error hander raised an error" Emque::Producing.logger.error ex Emque::Producing.logger.error Array(ex.backtrace).join("\n") end end end
host_name()
click to toggle source
# File lib/emque/producing/publisher/base.rb, line 5 def host_name Socket.gethostbyname(Socket.gethostname).first end