module Sidekiq::Haron

Constants

VERSION

Public Class Methods

configure_client_middleware(sidekiq_config) click to toggle source
# File lib/sidekiq/haron.rb, line 41
def self.configure_client_middleware(sidekiq_config)
  sidekiq_config.client_middleware do |chain|
    chain.add Sidekiq::Haron::ClientMiddleware
  end
end
configure_server_middleware(sidekiq_config) click to toggle source
# File lib/sidekiq/haron.rb, line 47
def self.configure_server_middleware(sidekiq_config)
  sidekiq_config.server_middleware do |chain|
    if Sidekiq.major_version < 5
      chain.insert_after Sidekiq::Middleware::Server::Logging,
        Sidekiq::Haron::ServerMiddleware
    else
      chain.add Sidekiq::Haron::ServerMiddleware
    end
  end
end
install(transmitter_class) click to toggle source
# File lib/sidekiq/haron.rb, line 22
def self.install transmitter_class
  Sidekiq::Haron.transmitter = transmitter_class.new
  set_loggers
  Sidekiq.configure_server do |c|
    configure_client_middleware(c)
    configure_server_middleware(c)
  end
  Sidekiq.configure_client do |c|
    configure_client_middleware(c)
  end
end
set_loggers() click to toggle source
# File lib/sidekiq/haron.rb, line 34
def self.set_loggers
  Sidekiq.options[:job_logger] = Sidekiq::Haron::JobLogger
  Sidekiq.logger.formatter = Sidekiq::Haron::Formatter.new
  Sidekiq.logger = ActiveSupport::TaggedLogging.new(Sidekiq.logger)
  Sidekiq::Haron::ExceptionLogger.install
end
transmitter() click to toggle source
# File lib/sidekiq/haron.rb, line 14
def self.transmitter
  Sidekiq.options[:transmitter]
end
transmitter=(v) click to toggle source
# File lib/sidekiq/haron.rb, line 18
def self.transmitter= v
  Sidekiq.options[:transmitter] = v
end