class Asynchronic::QueueEngine::Ost::Listener

Public Instance Methods

listen(queue, &block) click to toggle source
# File lib/asynchronic/queue_engine/ost.rb, line 84
def listen(queue, &block)
  @current_queue = queue
  Asynchronic.retry_execution(self.class, 'listen') do
    queue.each(&block)
  end
end
stop() click to toggle source
# File lib/asynchronic/queue_engine/ost.rb, line 91
def stop
  @current_queue.stop
end