Class: ActiveJob::QueueAdapters::ShoryukenAdapter::JobWrapper

Inherits:

Object

• Object
• ActiveJob::QueueAdapters::ShoryukenAdapter::JobWrapper

Includes:

Shoryuken::Worker

Defined in:

lib/shoryuken/extensions/active_job_adapter.rb

Overview

:nodoc:

Instance Method Summary

• #perform(sqs_msg, hash) ⇒ Object

Methods included from Shoryuken::Worker

included

Instance Method Details

#perform(sqs_msg, hash) ⇒ Object

# File 'lib/shoryuken/extensions/active_job_adapter.rb', line 88

def perform(sqs_msg, hash)
  receive_count = sqs_msg.attributes['ApproximateReceiveCount'].to_i
  past_receives = receive_count - 1
  Base.execute hash.merge({ 'executions' => past_receives })
end