Module: ThreadedInMemoryQueue::Timeout

Included in:
Master, Worker
Defined in:
lib/threaded_in_memory_queue/timeout.rb

Instance Method Summary collapse

Instance Method Details

#timeout(timeout, message = "", &block) ⇒ Object 



3
4
5
6
7
8
9
 
# File 'lib/threaded_in_memory_queue/timeout.rb', line 3

def timeout(timeout, message = "", &block)
  ::Timeout.timeout(timeout) do
    yield
  end
rescue ::Timeout::Error
  logger.error("Took longer than #{timeout} to #{message.inspect}")
end