class ElectricSlide

Constants

VERSION

Public Class Methods

create(name, queue_class = nil, *args) click to toggle source
# File lib/electric_slide.rb, line 46
def self.create(name, queue_class = nil, *args)
  fail "Queue with name #{name} already exists!" if get_queue(name)

  queue_class ||= CallQueue
  if !queue_class.respond_to?(:valid_with?) || queue_class.valid_with?(*args)
    @supervisor.supervise_as name, (queue_class || CallQueue), *args
    get_queue name
  end
end
get_queue(name) click to toggle source
# File lib/electric_slide.rb, line 60
def self.get_queue(name)
  @supervisor[name]
end
get_queue!(name) click to toggle source
# File lib/electric_slide.rb, line 56
def self.get_queue!(name)
  get_queue(name) || fail("Queue #{name} not found!")
end
queues_by_name() click to toggle source
# File lib/electric_slide.rb, line 39
def self.queues_by_name
  @supervisor.names.inject({}) do |queues, name|
    queues[name] = get_queue(name)
    queues
  end
end
shutdown_queue(name) click to toggle source
# File lib/electric_slide.rb, line 64
def self.shutdown_queue(name)
  queue = get_queue name
  queue.terminate if queue
end