class Kafka::PendingMessageQueue

Attributes

bytesize[R]
size[R]

Public Class Methods

new() click to toggle source
# File lib/kafka/pending_message_queue.rb, line 8
def initialize
  clear
end

Public Instance Methods

clear() click to toggle source
# File lib/kafka/pending_message_queue.rb, line 22
def clear
  @messages = []
  @size = 0
  @bytesize = 0
end
each(&block) click to toggle source

Yields each message in the queue.

@yieldparam [PendingMessage] message @return [nil]

# File lib/kafka/pending_message_queue.rb, line 37
def each(&block)
  @messages.each(&block)
end
empty?() click to toggle source
# File lib/kafka/pending_message_queue.rb, line 18
def empty?
  @messages.empty?
end
replace(messages) click to toggle source
# File lib/kafka/pending_message_queue.rb, line 28
def replace(messages)
  clear
  messages.each {|message| write(message) }
end
write(message) click to toggle source
# File lib/kafka/pending_message_queue.rb, line 12
def write(message)
  @messages << message
  @size += 1
  @bytesize += message.bytesize
end