Method: MessageBus::Implementation#timer

Defined in:
lib/message_bus.rb

#timer ⇒ Object 



354
355
356
357
358
359
360
361
362
363
 
# File 'lib/message_bus.rb', line 354

def timer
  return @timer_thread if @timer_thread
  @timer_thread ||= begin
    t = MessageBus::TimerThread.new
    t.on_error do |e|
      logger.warn "Failed to process job: #{e} #{e.backtrace}"
    end
    t
  end
end