Sha256: 2ddd601d2eb1beb6c2611efdff7cd822e63081ef49b531f9c949a3f09973cd8b

Contents?: true

Size: 1.18 KB

Versions: 5

Compression:

Stored size: 1.18 KB

Contents

# frozen_string_literal: true

require "sidekiq"

module SidekiqUniqueJobs
  #
  # Provides the sidekiq middleware that makes the gem work
  #
  # @author Mikael Henriksson <mikael@zoolutions.se>
  #
  module Middleware
    def self.extended(base)
      base.class_eval do
        configure_middleware
      end
    end

    def configure_middleware
      configure_server_middleware
      configure_client_middleware
    end

    def configure_server_middleware
      Sidekiq.configure_server do |config|
        config.client_middleware do |chain|
          require "sidekiq_unique_jobs/client/middleware"
          chain.add SidekiqUniqueJobs::Client::Middleware
        end

        config.server_middleware do |chain|
          require "sidekiq_unique_jobs/server/middleware"
          chain.add SidekiqUniqueJobs::Server::Middleware
        end
      end
    end

    def configure_client_middleware
      Sidekiq.configure_client do |config|
        config.client_middleware do |chain|
          require "sidekiq_unique_jobs/client/middleware"
          chain.add SidekiqUniqueJobs::Client::Middleware
        end
      end
    end
  end
end
SidekiqUniqueJobs.send(:extend, SidekiqUniqueJobs::Middleware)

Version data entries

5 entries across 5 versions & 1 rubygems

Version Path
sidekiq-unique-jobs-6.0.13 lib/sidekiq_unique_jobs/middleware.rb
sidekiq-unique-jobs-6.0.12 lib/sidekiq_unique_jobs/middleware.rb
sidekiq-unique-jobs-6.0.11 lib/sidekiq_unique_jobs/middleware.rb
sidekiq-unique-jobs-6.0.10 lib/sidekiq_unique_jobs/middleware.rb
sidekiq-unique-jobs-6.0.9 lib/sidekiq_unique_jobs/middleware.rb