class Aws::Rails::SqsActiveJob::JobRunner

@api private

def exception_executions?

def exception_executions?
  @job_data['exception_executions'] &&
    !@job_data['exception_executions'].empty?
end

def initialize(message)

def initialize(message)
  @job_data = Aws::Json.load(message.data.body)
  @class_name = @job_data['job_class'].constantize
  @id = @job_data['job_id']
end

def run

def run
  ActiveJob::Base.execute @job_data
end