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
84 85 86 87 88 89 |
# 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 ⇒ Object
91 92 93 |
# File 'lib/asynchronic/queue_engine/ost.rb', line 91 def stop @current_queue.stop end |