class BarbequeClient::Executor

Public Class Methods

new(job:, message:, message_id:, queue_name:) click to toggle source

@param [String] job - Job class name @param [String] message - JSON-serialized object @param [String] message_id - SQS mesasge_id @param [String] queue_name - barbeque's job_queues.name

# File lib/barbeque_client/executor.rb, line 9
def initialize(job:, message:, message_id:, queue_name:)
  @job        = job
  @message    = JSON.load(message)
  @message_id = message_id
  @queue_name = queue_name
end

Public Instance Methods

run() click to toggle source
# File lib/barbeque_client/executor.rb, line 16
def run
  ActiveJob::Base.execute(
    'job_class'  => @job,
    'job_id'     => @message_id,
    'queue_name' => @queue_name,
    'arguments'  => @message,
  )
end