Contents

require 'kafka_session/message'
require 'forwardable'

class KafkaSession
  class DeliveredMessage
    extend Forwardable

    delegate [:topic, :partition, :offset, :key] => :raw_message
    delegate [:value, :session_id, :published_at] => :message

    attr_reader :message, :raw_message, :session

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

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

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
kafka_session-0.2.0	lib/kafka_session/delivered_message.rb
kafka_session-0.1.0	lib/kafka_session/delivered_message.rb