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
24 25 26 27 28 29 30 31 32 |
# File 'lib/shoryuken/extensions/active_job_extensions.rb', line 24 def enqueue( = {}) = .extract! :message_attributes, :message_system_attributes, :message_deduplication_id, :message_group_id .merge! super end |
#initialize(*arguments) ⇒ Object
18 19 20 21 |
# File 'lib/shoryuken/extensions/active_job_extensions.rb', line 18 def initialize(*arguments) super(*arguments) self. = {} end |