Sha256: 4d2f2087f2d3b6b491bf13073fe2141980622ba6b1e09c81559fa913eb72ad6d

Contents?: true

Size: 529 Bytes

Versions: 4

Compression:

Stored size: 529 Bytes

Contents

# frozen_string_literal: true

begin
  require "sidekiq"
rescue LoadError
  # Sidekiq is not available, no need to load the adapter
  return
end

module JobIteration
  module InterruptionAdapters
    module SidekiqAdapter
      class << self
        attr_accessor :stopping

        def call
          stopping
        end
      end

      ::Sidekiq.configure_server do |config|
        config.on(:quiet) do
          SidekiqAdapter.stopping = true
        end
      end
    end

    register(:sidekiq, SidekiqAdapter)
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
job-iteration-1.7.0 lib/job-iteration/interruption_adapters/sidekiq_adapter.rb
job-iteration-1.6.0 lib/job-iteration/interruption_adapters/sidekiq_adapter.rb
job-iteration-1.5.1 lib/job-iteration/interruption_adapters/sidekiq_adapter.rb
job-iteration-1.5.0 lib/job-iteration/interruption_adapters/sidekiq_adapter.rb