Class: Kafka::PendingMessageQueue

Inherits:
Object
  • Object
show all
Defined in:
lib/kafka/pending_message_queue.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ PendingMessageQueue

Returns a new instance of PendingMessageQueue.



8
9
10
 
# File 'lib/kafka/pending_message_queue.rb', line 8

def initialize
  clear
end

Instance Attribute Details

#bytesize ⇒ Object (readonly)

Returns the value of attribute bytesize.



6
7
8
 
# File 'lib/kafka/pending_message_queue.rb', line 6

def bytesize
  @bytesize
end

#size ⇒ Object (readonly)

Returns the value of attribute size.



6
7
8
 
# File 'lib/kafka/pending_message_queue.rb', line 6

def size
  @size
end

Instance Method Details

#clear ⇒ Object 



22
23
24
25
26
 
# File 'lib/kafka/pending_message_queue.rb', line 22

def clear
  @messages = []
  @size = 0
  @bytesize = 0
end

#each {|message| ... } ⇒ nil

Yields each message in the queue.

Yield Parameters:

Returns:

  • (nil) 


37
38
39
 
# File 'lib/kafka/pending_message_queue.rb', line 37

def each(&block)
  @messages.each(&block)
end

#empty? ⇒ Boolean

Returns:

  • (Boolean) 


18
19
20
 
# File 'lib/kafka/pending_message_queue.rb', line 18

def empty?
  @messages.empty?
end

#replace(messages) ⇒ Object 



28
29
30
31
 
# File 'lib/kafka/pending_message_queue.rb', line 28

def replace(messages)
  clear
  messages.each {|message| write(message) }
end

#write(message) ⇒ Object 



12
13
14
15
16
 
# File 'lib/kafka/pending_message_queue.rb', line 12

def write(message)
  @messages << message
  @size += 1
  @bytesize += message.bytesize
end