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