Method: Kafka::Message#initialize

Defined in:
lib/kafka/message.rb

#initialize(payload = nil, magic = MAGIC_IDENTIFIER_DEFAULT, checksum = nil) ⇒ Message

Returns a new instance of Message.



47
48
49
50
51
52
 
# File 'lib/kafka/message.rb', line 47

def initialize(payload = nil, magic = MAGIC_IDENTIFIER_DEFAULT, checksum = nil)
  self.magic       = magic
  self.payload     = payload || ""
  self.checksum    = checksum || self.calculate_checksum
  @compression = NO_COMPRESSION
end