Module: Shoryuken::ActiveJobExtensions::SQSSendMessageParametersSupport

Defined in:
lib/shoryuken/extensions/active_job_extensions.rb

Overview

Initializes SQS SendMessage parameters on instances of ActiveJob::Base to the empty hash, and populates it whenever #enqueue is called, such as when using ActiveJob::Base.set.

Instance Method Summary collapse

Instance Method Details

#enqueue(options = {}) ⇒ Object 



26
27
28
29
30
31
32
33
34
 
# File 'lib/shoryuken/extensions/active_job_extensions.rb', line 26

def enqueue(options = {})
  sqs_options = options.extract! :message_attributes,
                                 :message_system_attributes,
                                 :message_deduplication_id,
                                 :message_group_id
  sqs_send_message_parameters.merge! sqs_options

  super
end

#initialize(*arguments) ⇒ Object 



20
21
22
23
 
# File 'lib/shoryuken/extensions/active_job_extensions.rb', line 20

def initialize(*arguments)
  super(*arguments)
  self.sqs_send_message_parameters = {}
end