module Ost

[](queue) click to toggle source

# File lib/ost.rb, line 62
def self.[](queue)
  @queues[queue]
end

redis() click to toggle source

# File lib/ost.rb, line 70
def self.redis
  @redis ||= Redic.new
end

redis=(redis) click to toggle source

# File lib/ost.rb, line 74
def self.redis=(redis)
  @redis = redis
end

stop() click to toggle source

# File lib/ost.rb, line 66
def self.stop
  @queues.each { |_, queue| queue.stop }
end