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