module IvoryTower::Queueable

Protected Instance Methods

queue() click to toggle source
# File lib/ivory_tower/queueable.rb, line 9
def queue
  if @queue
    return @queue if @queue.open?
    @queue.close_connection
  end
  @queue = IvoryTower::Queue.new queue_name
end
queue_name() click to toggle source
# File lib/ivory_tower/queueable.rb, line 5
def queue_name
  self.class.name.sub(/Consumer|Producer/, '') 
end