Class: Kiev::Kafka::MessageContext

Inherits:

Object

Object
Kiev::Kafka::MessageContext

show all

Defined in:: lib/kiev/kafka/message_context.rb

Instance Method Summary collapse

#initialize(message) ⇒ MessageContext constructor

A new instance of MessageContext.
#value(field) ⇒ Object (also: #[])

Constructor Details

#initialize(message) ⇒ `MessageContext`

Returns a new instance of MessageContext.

Parameters:

message (Kafka::FetchedMessage)



7
8
9

# File 'lib/kiev/kafka/message_context.rb', line 7

def initialize(message)
  @headers = message.headers
end

Instance Method Details

#value(field) ⇒ `Object` Also known as: []



11
12
13

# File 'lib/kiev/kafka/message_context.rb', line 11

def value(field)
  headers[header_key(field)] || headers[field.to_s]
end