Class: Woodhouse::Dispatcher

Inherits:

Object

• Object
• Woodhouse::Dispatcher

Defined in:

lib/woodhouse/dispatcher.rb

Direct Known Subclasses

Woodhouse::Dispatchers::CommonAmqpDispatcher, Woodhouse::Dispatchers::FileDispatcher, Woodhouse::Dispatchers::LocalDispatcher, Woodhouse::Dispatchers::LocalPoolDispatcher, Woodhouse::Dispatchers::TestDispatcher

Instance Method Summary

• #dispatch(class_name, job_method, arguments) ⇒ Object
• #dispatch_job(job) ⇒ Object
• #initialize(config, opts = {}, &blk) ⇒ Dispatcher constructor

  A new instance of Dispatcher.

• #update_job(job, data = {}) ⇒ Object

Constructor Details

#initialize(config, opts = {}, &blk) ⇒ Dispatcher

Returns a new instance of Dispatcher.

# File 'lib/woodhouse/dispatcher.rb', line 3

def initialize(config, opts = {}, &blk)
  @config = config
  after_initialize(config, opts = {}, &blk)
end

Instance Method Details

#dispatch(class_name, job_method, arguments) ⇒ Object

# File 'lib/woodhouse/dispatcher.rb', line 8

def dispatch(class_name, job_method, arguments)
  dispatch_job Woodhouse::Job.new(class_name, job_method, arguments)
end

#dispatch_job(job) ⇒ Object

# File 'lib/woodhouse/dispatcher.rb', line 12

def dispatch_job(job)
  @config.dispatcher_middleware.call(job) {|job|
    deliver_job(job)
  }
  job
end

#update_job(job, data = {}) ⇒ Object

# File 'lib/woodhouse/dispatcher.rb', line 19

def update_job(job, data = {})
  deliver_job_update(job, data)
end