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
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