module PikaQue

lifted from Sidekiq github.com/mperham/sidekiq/blob/master/lib/sidekiq/middleware/chain.rb

Constants

VERSION

Public Class Methods

config() click to toggle source
# File lib/pika_que.rb, line 18
def self.config
  @config ||= Configuration.new
end
configure(opts = {}) click to toggle source
# File lib/pika_que.rb, line 22
def self.configure(opts = {})
  config.merge!(opts)
end
connection() click to toggle source
# File lib/pika_que.rb, line 34
def self.connection
  @connection ||= Connection.create
end
logger() click to toggle source
# File lib/pika_que.rb, line 26
def self.logger
  PikaQue::Logging.logger
end
logger=(logger) click to toggle source
# File lib/pika_que.rb, line 30
def self.logger=(logger)
  PikaQue::Logging.logger = logger
end
middleware() { |chain| ... } click to toggle source
# File lib/pika_que.rb, line 38
def self.middleware
  @chain ||= Middleware::Chain.new
  yield @chain if block_given?
  @chain
end
reporters() { |reporters| ... } click to toggle source
# File lib/pika_que.rb, line 44
def self.reporters
  @reporters ||= [PikaQue::Reporters::LogReporter.new]
  yield @reporters if block_given?
  @reporters
end
reset!() click to toggle source
# File lib/pika_que.rb, line 50
def self.reset!
  @config = nil
  @connection = nil
  @chain = nil
  @reporters = nil
end