Module: PikaQue

Defined in:
lib/pika_que/middleware/chain.rb,
lib/pika_que.rb,
lib/pika_que/cli.rb,
lib/pika_que/util.rb,
lib/pika_que/rails.rb,
lib/pika_que/broker.rb,
lib/pika_que/errors.rb,
lib/pika_que/runner.rb,
lib/pika_que/worker.rb,
lib/pika_que/logging.rb,
lib/pika_que/metrics.rb,
lib/pika_que/version.rb,
lib/pika_que/launcher.rb,
lib/pika_que/processor.rb,
lib/pika_que/publisher.rb,
lib/pika_que/reporters.rb,
lib/pika_que/connection.rb,
lib/pika_que/subscriber.rb,
lib/pika_que/codecs/json.rb,
lib/pika_que/codecs/noop.rb,
lib/pika_que/codecs/rails.rb,
lib/pika_que/delay_worker.rb,
lib/pika_que/configuration.rb,
lib/pika_que/metrics/log_metric.rb,
lib/pika_que/metrics/null_metric.rb,
lib/pika_que/handlers/delay_handler.rb,
lib/pika_que/handlers/error_handler.rb,
lib/pika_que/handlers/retry_handler.rb,
lib/pika_que/reporters/log_reporter.rb,
lib/pika_que/handlers/default_handler.rb,
lib/pika_que/middleware/active_record.rb

Overview

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

Defined Under Namespace

Modules: Codecs, Handlers, Logging, Metrics, Middleware, Reporters, Util, Worker Classes: Broker, CLI, Configuration, Connection, DelayWorker, Launcher, Processor, Publisher, Rails, Runner, SetupError, Subscriber

Constant Summary collapse

VERSION = 
"0.1.2"

Class Method Summary collapse

Class Method Details

.config ⇒ Object 



17
18
19
 
# File 'lib/pika_que.rb', line 17

def self.config
  @config ||= Configuration.new
end

.connection ⇒ Object 



29
30
31
 
# File 'lib/pika_que.rb', line 29

def self.connection
  @connection ||= Connection.create
end

.logger ⇒ Object 



21
22
23
 
# File 'lib/pika_que.rb', line 21

def self.logger
  PikaQue::Logging.logger
end

.logger=(logger) ⇒ Object 



25
26
27
 
# File 'lib/pika_que.rb', line 25

def self.logger=(logger)
  PikaQue::Logging.logger = logger
end

.middleware {|@chain| ... } ⇒ Object

Yields:

  • (@chain) 


33
34
35
36
37
 
# File 'lib/pika_que.rb', line 33

def self.middleware
  @chain ||= Middleware::Chain.new
  yield @chain if block_given?
  @chain
end

.reporters ⇒ Object 



39
40
41
42
 
# File 'lib/pika_que.rb', line 39

def self.reporters
  config[:reporters] << PikaQue::Reporters::LogReporter.new if config[:reporters].empty?
  config[:reporters]
end