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/codecs.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/handlers.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/rails_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,
lib/pika_que/middleware/request_store.rb,
lib/pika_que/handlers/dlx_retry_handler.rb

Overview

Add manually if you need it

Defined Under Namespace

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

Constant Summary collapse

VERSION = 
"0.3.0"

Class Method Summary collapse

Class Method Details

.config ⇒ Object 



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

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

.configure(opts = {}) ⇒ Object 



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

def self.configure(opts = {})
  config.merge!(opts)
end

.connection ⇒ Object 



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

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

.logger ⇒ Object 



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

def self.logger
  PikaQue::Logging.logger
end

.logger=(logger) ⇒ Object 



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

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

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

Yields:

  • (@chain) 


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

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

.reporters {|@reporters| ... } ⇒ Object

Yields:



44
45
46
47
48
 
# File 'lib/pika_que.rb', line 44

def self.reporters
  @reporters ||= [PikaQue::Reporters::LogReporter.new]
  yield @reporters if block_given?
  @reporters
end

.reset! ⇒ Object 



50
51
52
53
54
55
 
# File 'lib/pika_que.rb', line 50

def self.reset!
  @config = nil
  @connection = nil
  @chain = nil
  @reporters = nil
end