lib/deimos/kafka_message.rb in deimos-ruby-1.0.0.pre.beta22 vs lib/deimos/kafka_message.rb in deimos-ruby-1.0.0.pre.beta23

- old
+ new

@@ -3,11 +3,11 @@ module Deimos # Store Kafka messages into the database. class KafkaMessage < ActiveRecord::Base self.table_name = 'kafka_messages' - validates_presence_of :message, :topic + 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] def message=(mess) @@ -21,7 +21,8 @@ partition_key: self.partition_key, key: self.key, topic: self.topic } end + end end