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