module Riaq

Constants

PENDING
PROCESSING

Public Class Methods

[](queue) click to toggle source 
# File lib/riaq.rb, line 75
def self.[](queue)
  @queues[queue]
end
connect(options = {}) click to toggle source 
# File lib/riaq.rb, line 85
def self.connect(options = {})
  @options = options
end
options() click to toggle source 
# File lib/riaq.rb, line 89
def self.options
  @options || {}
end
stop() click to toggle source 
# File lib/riaq.rb, line 79
def self.stop
  @queues.each { |_, queue| queue.stop }
end