Module: Ost

Defined in:

lib/ost.rb

Defined Under Namespace

Classes: Queue

Constant Summary

VERSION =

"0.1.2"

TIMEOUT =

ENV["OST_TIMEOUT"] || 2

Class Method Summary

• .[](queue) ⇒ Object
• .connect(options = {}) ⇒ Object
• .options ⇒ Object
• .stop ⇒ Object

Class Method Details

.[](queue) ⇒ Object

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

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

.connect(options = {}) ⇒ Object

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

def self.connect(options = {})
  @options = options
end

.options ⇒ Object

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

def self.options
  @options || {}
end

.stop ⇒ Object

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

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