class KafkaSession::DeliveredMessage

Attributes

message[R]
raw_message[R]

Public Class Methods

new(raw_message) click to toggle source
# File lib/kafka_session/delivered_message.rb, line 13
def initialize(raw_message)
  @raw_message = raw_message
  @message     = Message.parse(raw_message.value)
end

Public Instance Methods

session() click to toggle source
# File lib/kafka_session/delivered_message.rb, line 18
def session
  @session ||= KafkaSession.new(id: message.session_id)
end