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.