class Aws::Rails::SqsActiveJob::JobRunner

Attributes

class_name[R]
id[R]

Public Class Methods

new(message) click to toggle source
# File lib/aws/rails/sqs_active_job/job_runner.rb, line 10
def initialize(message)
  @job_data = Aws::Json.load(message.data.body)
  @class_name = @job_data['job_class'].constantize
  @id = @job_data['job_id']
end

Public Instance Methods

run() click to toggle source
# File lib/aws/rails/sqs_active_job/job_runner.rb, line 16
def run
  ActiveJob::Base.execute @job_data
end