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