Module: Reliable

Defined in:

lib/reliable.rb,
lib/reliable/list.rb,
lib/reliable/uuid.rb,
lib/reliable/queue.rb,
lib/reliable/redis.rb,
lib/reliable/worker.rb,
lib/reliable/version.rb

Defined Under Namespace

Classes: List, NullLogger, Queue, Redis, UUID, Worker

Constant Summary

POP_TIMEOUT =

ENV.fetch("RELIABLE_TIMEOUT", "2").to_i

TIME_TRAVEL_DELAY =

ENV.fetch("RELIABLE_TIME_TRAVEL_DELAY", "60").to_i

PROCESSING_TIMEOUT =

ENV.fetch("PROCESSING_TIMEOUT", "120").to_i

MalformedUUID =

Class.new(StandardError)

VERSION =

"0.1.0"

Class Method Summary

• .[](queue) ⇒ Object
• .logger ⇒ Object
• .logger=(new_logger) ⇒ Object

Class Method Details

.[](queue) ⇒ Object

# File 'lib/reliable.rb', line 14

def self.[](queue)
  @queues[queue]
end

.logger ⇒ Object

# File 'lib/reliable.rb', line 26

def self.logger
  @logger ||= NullLogger.new
end

.logger=(new_logger) ⇒ Object

# File 'lib/reliable.rb', line 30

def self.logger=(new_logger)
  @logger = new_logger
end