Module: Aws::ActiveJob::SQS

Defined in:
lib/aws-activejob-sqs.rb,
lib/aws/active_job/sqs/poller.rb,
lib/aws/active_job/sqs/executor.rb,
lib/aws/active_job/sqs/job_runner.rb,
lib/aws/active_job/sqs/cli_options.rb,
lib/aws/active_job/sqs/configuration.rb,
lib/aws/active_job/sqs/deduplication.rb,
lib/aws/active_job/sqs/lambda_handler.rb

Overview

ActiveJob Adapter and backend queueing using AWS SQS.

Defined Under Namespace

Modules: CliOptions, Deduplication, LambdaHandler Classes: Configuration, Executor, JobRunner, Poller

Constant Summary collapse

VERSION = 
File.read(File.expand_path('../VERSION', __dir__)).strip

Class Method Summary collapse

Class Method Details

.config ⇒ Configuration

Returns the (singleton) Configuration.

Returns:



20
21
22
 
# File 'lib/aws-activejob-sqs.rb', line 20

def self.config
  @config ||= Configuration.new
end

.configure {|Configuration| ... } ⇒ Object

Yields:



25
26
27
 
# File 'lib/aws-activejob-sqs.rb', line 25

def self.configure
  yield(config)
end

.fifo?(queue_url) ⇒ Boolean

Returns true if the queue_url is a FIFO queue.

Parameters:

  • queue_url (String)

Returns:

  • (Boolean) —

    true if the queue_url is a FIFO queue



31
32
33
 
# File 'lib/aws-activejob-sqs.rb', line 31

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

.on_worker_stop ⇒ Object 



35
36
37
 
# File 'lib/aws-activejob-sqs.rb', line 35

def self.on_worker_stop(...)
  Executor.on_stop(...)
end