Contents

# frozen_string_literal: true

module Yael
  class DispatchJob < ActiveJob::Base
    retry_on ActiveRecord::Deadlocked

    queue_as :dispatch

    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
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
yael-0.0.3	lib/yael/dispatch_job.rb
yael-0.0.2	lib/yael/dispatch_job.rb