Method: Kafka::PendingMessageQueue#replace

Defined in:
lib/kafka/pending_message_queue.rb

#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