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