Contents

# frozen_string_literal: true

module AdvancedSneakersActiveJob
  module ActiveJobPatch
    extend ActiveSupport::Concern

    included do
      # AMQP message contains metadata which might be helpful for consumer (e.g. job.delivery_info.routing_key)
      attr_accessor :delivery_info, :headers, :publish_options

      class_attribute :publish_options, instance_accessor: false
    end

    module ClassMethods
      def deserialize(job_data)
        super(job_data).tap do |job|
          job.delivery_info = job_data['delivery_info']
          job.headers = job_data['headers']
        end
      end

      def message_options(options)
        raise ArgumentError, 'message_options accepts Hash argument only' unless options.is_a?(Hash)

        self.publish_options = options.symbolize_keys
      end
    end

    def enqueue(options = {})
      # Since ActiveJob v5 :priority option is supported natively https://github.com/rails/rails/pull/19425
      # publish_options holds its own :priority to "backport" priority feature to ActiveJob v4
      self.publish_options = options.except(:wait, :wait_until, :queue)

      super
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
advanced-sneakers-activejob-0.6.0	lib/advanced_sneakers_activejob/active_job_patch.rb
advanced-sneakers-activejob-0.5.0	lib/advanced_sneakers_activejob/active_job_patch.rb
advanced-sneakers-activejob-0.4.0	lib/advanced_sneakers_activejob/active_job_patch.rb