class ActiveJob::QueueAdapters::AmazonSqsAsyncAdapter

Async adapter for Amazon SQS ActiveJob

This adapter queues jobs asynchronously (ie non-blocking). Error handler can be configured with Aws::Rails::SqsActiveJob.config.async_queue_error_handler.

To use this adapter, set up as:

config.active_job.queue_adapter = :amazon_sqs_async

Private Instance Methods

_enqueue(job, send_message_opts = {}) click to toggle source
Calls superclass method ActiveJob::QueueAdapters::AmazonSqsAdapter#_enqueue
# File lib/active_job/queue_adapters/amazon_sqs_async_adapter.rb, line 21
def _enqueue(job, send_message_opts = {})
  # FIFO jobs must be queued in order, so do not queue async
  queue_url = Aws::Rails::SqsActiveJob.config.queue_url_for(job.queue_name)
  if Aws::Rails::SqsActiveJob.fifo?(queue_url)
    super(job, send_message_opts)
  else
    Concurrent::Promise
    .execute { super(job, send_message_opts) }
    .on_error do |e|
      Rails.logger.error "Failed to queue job #{job}.  Reason: #{e}"
      error_handler = Aws::Rails::SqsActiveJob.config.async_queue_error_handler
      error_handler.call(e, job, send_message_opts) if error_handler
    end
  end
end