Class: ActiveJob::QueueAdapters::AdvancedSneakersAdapter::JobWrapper

Inherits:
Object
  • Object
show all
Defined in:
lib/active_job/queue_adapters/advanced_sneakers_adapter.rb

Overview

:nodoc:

Instance Method Summary collapse

Instance Method Details

#work_with_params(msg, delivery_info, headers) ⇒ Object 



75
76
77
78
79
80
81
82
83
 
# File 'lib/active_job/queue_adapters/advanced_sneakers_adapter.rb', line 75

def work_with_params(msg, delivery_info, headers)
  # compatibility with :sneakers adapter
  msg = ActiveSupport::JSON.decode(msg) unless headers[:content_type] == AdvancedSneakersActiveJob::CONTENT_TYPE

  msg['delivery_info'] = delivery_info
  msg['headers'] = headers
  Base.execute msg
  ack!
end