Contents

# frozen_string_literal: true

require_relative '../../active_job/queue_adapters/sqs_adapter'
require_relative '../../active_job/queue_adapters/sqs_adapter/params'
require_relative '../../active_job/queue_adapters/sqs_async_adapter'
require_relative 'sqs_active_job/configuration'
require_relative 'sqs_active_job/deduplication'
require_relative 'sqs_active_job/executor'
require_relative 'sqs_active_job/job_runner'
require_relative 'sqs_active_job/lambda_handler'

module Aws
  module Rails
    # == AWS SQS ActiveJob.
    #
    # SQS-based queuing backend for Active Job.
    module SqsActiveJob
      # @return [Configuration] the (singleton) Configuration
      def self.config
        @config ||= Configuration.new
      end

      # @yield Configuration
      def self.configure
        yield(config)
      end

      def self.fifo?(queue_url)
        queue_url.ends_with? '.fifo'
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
aws-sdk-rails-4.1.0	lib/aws/rails/sqs_active_job.rb
aws-sdk-rails-4.0.3	lib/aws/rails/sqs_active_job.rb
aws-sdk-rails-4.0.2	lib/aws/rails/sqs_active_job.rb