Class: KafkaSession::DeliveredMessage

Inherits:
Object
  • Object
show all
Extended by:
Forwardable
Defined in:
lib/kafka_session/delivered_message.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(raw_message) ⇒ DeliveredMessage

Returns a new instance of DeliveredMessage.



13
14
15
16
 
# File 'lib/kafka_session/delivered_message.rb', line 13

def initialize(raw_message)
  @raw_message = raw_message
  @message     = Message.parse(raw_message.value)
end

Instance Attribute Details

#message ⇒ Object (readonly)

Returns the value of attribute message.



11
12
13
 
# File 'lib/kafka_session/delivered_message.rb', line 11

def message
  @message
end

#raw_message ⇒ Object (readonly)

Returns the value of attribute raw_message.



11
12
13
 
# File 'lib/kafka_session/delivered_message.rb', line 11

def raw_message
  @raw_message
end

Instance Method Details

#session ⇒ Object 



18
19
20
 
# File 'lib/kafka_session/delivered_message.rb', line 18

def session
  @session ||= KafkaSession.new(id: message.session_id)
end