Class: Sidekiq::ReliableJob::ServerMiddleware

Inherits:
Object
  • Object
show all
Includes:
ServerMiddleware
Defined in:
lib/sidekiq/reliable_job/server_middleware.rb

Overview

Deletes staged jobs from the Outbox after successful completion.

Instance Method Summary collapse

Instance Method Details

#call(_job_instance, job_payload, _queue) ⇒ Object 



11
12
13
14
15
16
17
 
# File 'lib/sidekiq/reliable_job/server_middleware.rb', line 11

def call(_job_instance, job_payload, _queue)
  yield
ensure
  if $ERROR_INFO.nil? && job_payload["reliable_job"]
    delete_staged_job(job_payload["jid"])
  end
end