Contents

module Kafka
  module Protocol
    class MessageSet
      attr_reader :messages

      def initialize(messages:)
        @messages = messages
      end

      def self.decode(decoder)
        fetched_messages = []

        until decoder.eof?
          offset = decoder.int64
          message_decoder = Decoder.from_string(decoder.bytes)
          message = Message.decode(message_decoder)

          fetched_messages << [offset, message]
        end

        new(messages: fetched_messages)
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
ruby-kafka-0.1.5	lib/kafka/protocol/message_set.rb
ruby-kafka-0.1.4	lib/kafka/protocol/message_set.rb