Method: TaskTempest::Bootstrap#dispatcher

Defined in:
lib/task_tempest/bootstrap.rb

#dispatcher ⇒ Object 



51
52
53
54
55
56
57
58
59
 
# File 'lib/task_tempest/bootstrap.rb', line 51

def dispatcher
  @dispatcher ||= begin
    Dispatcher.new :logger => logger,
                   :task_logger => task_logger,
                   :queue_factory => Proc.new{ settings.queue.call(logger) },
                   :storm => storm,
                   :no_message_sleep => settings.no_message_sleep
  end
end