module Sidekiq::SortedEntry::UniqueExtension

Provides extensions for unlocking jobs that are removed and deleted

@author Mikael Henriksson <mikael@mhenrixon.com>

Public Instance Methods

delete() click to toggle source

Wraps the original method to ensure locks for the job are deleted

@return [Hash] the deleted sidekiq job hash

Calls superclass method
# File lib/sidekiq_unique_jobs/sidekiq_unique_ext.rb, line 23
def delete
  SidekiqUniqueJobs::Unlockable.delete!(item) if super
  item
end

Private Instance Methods

remove_job() { |message| ... } click to toggle source

Wraps the original method to ensure locks for the job are deleted

@yieldparam [Hash] message the sidekiq job hash

Calls superclass method
# File lib/sidekiq_unique_jobs/sidekiq_unique_ext.rb, line 35
def remove_job
  super do |message|
    SidekiqUniqueJobs::Unlockable.delete!(Sidekiq.load_json(message))
    yield message
  end
end