class Kiev::Shoryuken::Middleware::StoreRequestDetails

Public Instance Methods

call(_worker, _queue, message, _body) { || ... } click to toggle source
# File lib/kiev/shoryuken/middleware/store_request_details.rb, line 9
def call(_worker, _queue, message, _body)
  context_reader = Kiev::Shoryuken::ContextReader.new(message)
  Config.instance.jobs_propagated_fields.each do |key|
    Kiev[key] = context_reader[key]
  end
  request_store = Kiev::RequestStore.store
  request_store[:background_job] = true
  request_store[:message_id] = message.message_id
  yield
end