Contents

# frozen_string_literal: true

require "resque"

module JobIteration
  module Integrations
    module ResqueIterationExtension # @private
      def initialize(*) # @private
        $resque_worker = self
        super
      end
    end

    # @private
    module ::Resque
      class Worker
        # The patch is required in order to call shutdown? on a Resque::Worker instance
        prepend(ResqueIterationExtension)
      end
    end

    JobIteration.interruption_adapter = -> { $resque_worker.try!(:shutdown?) }
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
job-iteration-1.4.1	lib/job-iteration/integrations/resque.rb
job-iteration-1.4.0	lib/job-iteration/integrations/resque.rb
job-iteration-1.3.6	lib/job-iteration/integrations/resque.rb
job-iteration-1.3.5	lib/job-iteration/integrations/resque.rb
job-iteration-1.3.4	lib/job-iteration/integrations/resque.rb