class Kiev::Kafka::ContextInjector
Public Instance Methods
call(headers = {})
click to toggle source
@param [Hash] headers Injects context headers @return [Hash]
# File lib/kiev/kafka/context_injector.rb, line 11 def call(headers = {}) Kiev::SubrequestHelper.payload.each do |key, value| field_key = Kiev::Config::DEFAULT_HTTP_PROPAGATED_FIELDS.fetch(key.to_sym, key) headers[field_key] = value end headers end