class SidekiqUniqueJobs::Server

The unique sidekiq middleware for the server processor

@author Mikael Henriksson <mikael@mhenrixon.com>

Constants

DEATH_HANDLER

Public Class Methods

configure(config) click to toggle source

Configure the server middleware

@return [Sidekiq] the sidekiq configuration

# File lib/sidekiq_unique_jobs/server.rb, line 19
def self.configure(config)
  config.on(:startup)  { start }
  config.on(:shutdown) { stop }

  return unless config.respond_to?(:death_handlers)

  config.death_handlers << death_handler
end
death_handler() click to toggle source

A death handler for dead jobs

@return [lambda]

# File lib/sidekiq_unique_jobs/server.rb, line 57
def self.death_handler
  DEATH_HANDLER
end
start() click to toggle source

Start the sidekiq unique jobs server process

@return [void]

# File lib/sidekiq_unique_jobs/server.rb, line 34
def self.start
  SidekiqUniqueJobs::UpdateVersion.call
  SidekiqUniqueJobs::UpgradeLocks.call
  SidekiqUniqueJobs::Orphans::Manager.start
  SidekiqUniqueJobs::Orphans::ReaperResurrector.start
end
stop() click to toggle source

Stop the sidekiq unique jobs server process

@return [void]

# File lib/sidekiq_unique_jobs/server.rb, line 47
def self.stop
  SidekiqUniqueJobs::Orphans::Manager.stop
end