Class: Kafka::Batch

Inherits:

Object

• Object
• Kafka::Batch

Defined in:

lib/kafka/batch.rb

Instance Attribute Summary

• #messages ⇒ Object

  Returns the value of attribute messages.

Instance Method Summary

• #<<(message) ⇒ Object
• #initialize ⇒ Batch constructor

  A new instance of Batch.

Constructor Details

#initialize ⇒ Batch

Returns a new instance of Batch.

# File 'lib/kafka/batch.rb', line 20

def initialize
  self.messages = []
end

Instance Attribute Details

#messages ⇒ Object

Returns the value of attribute messages.

# File 'lib/kafka/batch.rb', line 18

def messages
  @messages
end

Instance Method Details

#<<(message) ⇒ Object

# File 'lib/kafka/batch.rb', line 24

def << (message)
  self.messages << message
end