lib/deimos/kafka_message.rb in deimos-ruby-1.16.3 vs lib/deimos/kafka_message.rb in deimos-ruby-1.16.4

- old
+ new

@@ -8,9 +8,10 @@ validates_presence_of :topic # Ensure it gets turned into a string, e.g. for testing purposes. It # should already be a string. # @param mess [Object] + # @return [void] def message=(mess) write_attribute(:message, mess ? mess.to_s : nil) end # Decoded payload for this message.