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