sidekiq_middeware_job_complete.rb

module Middleware::Server
  class OnJobComplete
    def call(worker, msg, queue)
      yield
      args_to_job = msg["args"]
      worker.on_job_complete(args_to_job) if worker.respond_to?(:on_job_complete)
    end
  end
end