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