class Yael::DispatchJob

Public Instance Methods

perform(name:, stream:, payload:, created_at:, persist: true) click to toggle source
# 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