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