3scale/porta

# frozen_string_literal: true

class ZyncSubscriber < AfterCommitSubscriber

  def initialize(job = ZyncWorker)
    @job = job
    freeze
  end

  attr_reader :job

  # @param [ZyncEvent] event
  def after_commit(event)
    job.perform_async(event.event_id, event.data.as_json)
  end
end