class Qs::DispatchJob

Public Class Methods

event(job) click to toggle source
# File lib/qs/dispatch_job.rb, line 9
def self.event(job)
  Qs::Event.new(job.params['event_channel'], job.params['event_name'], {
    :params       => job.params['event_params'],
    :publisher    => job.params['event_publisher'],
    :published_at => job.created_at
  })
end
new(event_channel, event_name, options = nil) click to toggle source
Calls superclass method Qs::Job::new
# File lib/qs/dispatch_job.rb, line 17
def initialize(event_channel, event_name, options = nil)
  options ||= {}
  event_params    = options.delete(:event_params)    || {}
  event_publisher = options.delete(:event_publisher) || Qs.event_publisher
  options[:params] = {
    'event_channel'   => event_channel,
    'event_name'      => event_name,
    'event_params'    => event_params,
    'event_publisher' => event_publisher
  }
  super(Qs.dispatcher_job_name, options)
end

Public Instance Methods

event() click to toggle source
# File lib/qs/dispatch_job.rb, line 30
def event
  @event ||= self.class.event(self)
end