Module: Aws::ActiveJob::SQS

Defined in:
lib/aws-activejob-sqs.rb,
lib/aws/active_job/sqs/errors.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, FifoDelayNotSupportedError, InvalidJobClassError, 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:



22
23
24
 
# File 'lib/aws-activejob-sqs.rb', line 22

def config
  @config ||= Configuration.new
end

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

Yields:



27
28
29
 
# File 'lib/aws-activejob-sqs.rb', line 27

def 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



33
34
35
 
# File 'lib/aws-activejob-sqs.rb', line 33

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

.on_worker_stop ⇒ Object 



37
38
39
 
# File 'lib/aws-activejob-sqs.rb', line 37

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