Class: SidekiqUniqueJobs::Server

Inherits:
Object
  • Object
show all
Defined in:
lib/sidekiq_unique_jobs/server.rb

Overview

The unique sidekiq middleware for the server processor

Author:

Class Method Summary collapse

Class Method Details

.configure(config) ⇒ Sidekiq

Configure the server middleware

Returns:

  • (Sidekiq) —

    the sidekiq configuration



19
20
21
22
23
24
25
26
 
# 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 ⇒ lambda

A death handler for dead jobs

Returns:

  • (lambda) 


45
46
47
 
# File 'lib/sidekiq_unique_jobs/server.rb', line 45

def self.death_handler
  DEATH_HANDLER
end

.start ⇒ Object 



28
29
30
31
32
33
 
# File 'lib/sidekiq_unique_jobs/server.rb', line 28

def self.start
  SidekiqUniqueJobs::UpdateVersion.call
  SidekiqUniqueJobs::UpgradeLocks.call
  SidekiqUniqueJobs::Orphans::Manager.start
  SidekiqUniqueJobs::Orphans::ReaperResurrector.start
end

.stop ⇒ Object 



35
36
37
 
# File 'lib/sidekiq_unique_jobs/server.rb', line 35

def self.stop
  SidekiqUniqueJobs::Orphans::Manager.stop
end