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