Sha256: a0f31152bde0175c6fbc5f9bc3e89e21629602d016c45ecc3e72511ee0cdf194
Contents?: true
Size: 872 Bytes
Versions: 10
Compression:
Stored size: 872 Bytes
Contents
require 'socket'
require 'sidekiq/exception_handler'
require 'sidekiq/core_ext'
module Sidekiq
##
# This module is part of Sidekiq core and not intended for extensions.
#
module Util
include ExceptionHandler
EXPIRY = 60 * 60 * 24
def watchdog(last_words)
yield
rescue Exception => ex
handle_exception(ex, { :context => last_words })
raise ex
end
def logger
Sidekiq.logger
end
def redis(&block)
Sidekiq.redis(&block)
end
def hostname
ENV['DYNO'] || Socket.gethostname
end
def identity
@@identity ||= "#{hostname}:#{$$}"
end
def fire_event(event)
Sidekiq.options[:lifecycle_events][event].each do |block|
begin
block.call
rescue => ex
handle_exception(ex, { :event => event })
end
end
end
end
end
Version data entries
10 entries across 10 versions & 1 rubygems