Contents

module ActsAsTenant
  module ActiveJobExtensions
    def serialize
      super.merge("current_tenant" => ActsAsTenant.current_tenant&.to_global_id&.to_s)
    end

    def deserialize(job_data)
      tenant_global_id = job_data.delete("current_tenant")
      ActsAsTenant.current_tenant = tenant_global_id ? GlobalID::Locator.locate(tenant_global_id) : nil
      super
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
acts_as_tenant-1.0.1	lib/acts_as_tenant/active_job_extensions.rb