Class: Yael::DispatchJob

Inherits:
ActiveJob::Base
  • Object
show all
Defined in:
lib/yael/dispatch_job.rb

Instance Method Summary collapse

Instance Method Details

#perform(name:, stream:, payload:, created_at:, persist: true) ⇒ Object 



9
10
11
12
13
 
# File 'lib/yael/dispatch_job.rb', line 9

def perform(name:, stream:, payload:, created_at:, persist: true)
  event = Event.new name: name, stream: stream, payload: payload, created_at: created_at
  event.save! if persist
  Yael::Bus.shared.process(event)
end