class KafkaSession::Message
Attributes
published_at[R]
session_id[R]
value[R]
Public Class Methods
new(value, session_id:, published_at: KafkaSession.now)
click to toggle source
# File lib/kafka_session/message.rb, line 18 def initialize(value, session_id:, published_at: KafkaSession.now) @value = value @session_id = session_id @published_at = published_at end
parse(json_message_value)
click to toggle source
# File lib/kafka_session/message.rb, line 8 def self.parse(json_message_value) parsed = JSON.parse(json_message_value) new( parsed["value"], session_id: parsed["session_id"], published_at: parsed["published_at"] ) end
Public Instance Methods
to_json()
click to toggle source
# File lib/kafka_session/message.rb, line 24 def to_json { value: value, session_id: session_id, published_at: published_at.to_i }.to_json end