lib/deimos/utils/db_producer.rb in deimos-ruby-1.0.0.pre.beta23 vs lib/deimos/utils/db_producer.rb in deimos-ruby-1.0.0.pre.beta24

@@ -18,10 +18,11 @@
 
       # Start the poll.
       def start
         @logger.info('Starting...')
         @signal_to_stop = false
+        ActiveRecord::Base.connection.reconnect!
         loop do
           if @signal_to_stop
             @logger.info('Shutting down')
             break
           end
@@ -67,11 +68,11 @@
             decoded_messages = if producer
                                  consumer = Class.new(Deimos::Consumer)
                                  consumer.config.merge!(producer.config)
                                  messages.map do |message|
                                    {
-                                     :key => message[:key].present? ? consumer.new.decode_key(message[:key]) : nil,
-                                     :message => consumer.decoder.decode(message[:payload])
+                                     key: message[:key].present? ? consumer.new.decode_key(message[:key]) : nil,
+                                     message: consumer.decoder.decode(message[:payload])
                                    }
                                  end
                                else
                                  messages
                                end