Module: Ost

Defined in:

lib/ost.rb

Defined Under Namespace

Classes: Queue

Constant Summary

TIMEOUT =

ENV["OST_TIMEOUT"] || "2"

Class Method Summary

• .[](queue) ⇒ Object
• .redis ⇒ Object
• .redis=(redis) ⇒ Object
• .stop ⇒ Object

Class Method Details

.[](queue) ⇒ Object

# File 'lib/ost.rb', line 62

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

.redis ⇒ Object

# File 'lib/ost.rb', line 70

def self.redis
  @redis ||= Redic.new
end

.redis=(redis) ⇒ Object

# File 'lib/ost.rb', line 74

def self.redis=(redis)
  @redis = redis
end

.stop ⇒ Object

# File 'lib/ost.rb', line 66

def self.stop
  @queues.each { |_, queue| queue.stop }
end