Class: Asynchronic::QueueEngine::Ost::Listener
- Inherits:
-
Object
- Object
- Asynchronic::QueueEngine::Ost::Listener
- Defined in:
- lib/asynchronic/queue_engine/ost.rb
Instance Method Summary collapse
Instance Method Details
#listen(queue, &block) ⇒ Object
64 65 66 67 68 69 |
# File 'lib/asynchronic/queue_engine/ost.rb', line 64 def listen(queue, &block) @current_queue = queue Asynchronic.retry_execution(self.class, 'listen') do queue.each &block end end |
#stop ⇒ Object
71 72 73 |
# File 'lib/asynchronic/queue_engine/ost.rb', line 71 def stop @current_queue.stop end |