class QPush::Server::Apis::Success

Public Instance Methods

call() click to toggle source
# File lib/qpush/server/apis/success.rb, line 5
def call
  update_job
  stat_increment
  log_success
  update_history
end

Private Instance Methods

log_success() click to toggle source
# File lib/qpush/server/apis/success.rb, line 23
def log_success
  Server.log.info("Worker #{Server.worker.id} | Job SUCCESS | #{@job.klass} with ID: #{@job.id} | #{@job.run_time}")
end
stat_increment() click to toggle source
# File lib/qpush/server/apis/success.rb, line 19
def stat_increment
  Server.redis { |c| c.hincrby(Server.keys[:stats], 'success', 1) }
end
update_history() click to toggle source
# File lib/qpush/server/apis/success.rb, line 27
def update_history
  History.call(@job, true, nil)
end
update_job() click to toggle source
# File lib/qpush/server/apis/success.rb, line 14
def update_job
  @job.mark_success
  @job.delay if @job.delay_job?
end