class Kiev::Kafka::MessageContext

Attributes

headers[R]

Public Class Methods

new(message) click to toggle source

@param [Kafka::FetchedMessage] message

# File lib/kiev/kafka/message_context.rb, line 7
def initialize(message)
  @headers = message.headers
end

Public Instance Methods

[](field)
Alias for: value
value(field) click to toggle source
# File lib/kiev/kafka/message_context.rb, line 11
def value(field)
  headers[header_key(field)] || headers[field.to_s]
end
Also aliased as: []

Private Instance Methods

header_key(field) click to toggle source

@param [String] field

# File lib/kiev/kafka/message_context.rb, line 22
def header_key(field)
  "x_#{field}".gsub("_", " ").split.map(&:capitalize).join("-")
end