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