module Shoryuken::ActiveJobExtensions::SQSSendMessageParametersSupport

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

Public Class Methods

new(*arguments) click to toggle source
Calls superclass method
# File lib/shoryuken/extensions/active_job_extensions.rb, line 18
def initialize(*arguments)
  super(*arguments)
  self.sqs_send_message_parameters = {}
end

Public Instance Methods

enqueue(options = {}) click to toggle source
Calls superclass method
# File lib/shoryuken/extensions/active_job_extensions.rb, line 24
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