class Aws::Rails::SqsActiveJob::JobRunner
@api private
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
exception_executions?()
click to toggle source
# File lib/aws/rails/sqs_active_job/job_runner.rb, line 20 def exception_executions? @job_data['exception_executions'] && !@job_data['exception_executions'].empty? end
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