Contents

# frozen_string_literal: true

require "active_job/serializers/object_serializer"

module AcidicJob
  module Serializers
    class WorkerSerializer < ::ActiveJob::Serializers::ObjectSerializer
      def serialize(worker)
        super(
          "job_class" => worker.class.name
        )
      end

      def deserialize(hash)
        worker_class = hash["job_class"].constantize
        worker_class.new
      end

      def serialize?(argument)
        defined?(::Sidekiq) && argument.class.include?(::Sidekiq::Worker) &&
          !(defined?(::AcidicJob::ActiveKiq) && argument.class < ::AcidicJob::ActiveKiq)
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
acidic_job-0.9.0	lib/acidic_job/serializers/worker_serializer.rb
acidic_job-0.8.8	lib/acidic_job/serializers/worker_serializer.rb
acidic_job-0.8.7	lib/acidic_job/serializers/worker_serializer.rb
acidic_job-0.8.5	lib/acidic_job/serializers/worker_serializer.rb
acidic_job-0.8.4	lib/acidic_job/serializers/worker_serializer.rb