lib/tasks/messages.rake in mumuki-laboratory-9.5.1 vs lib/tasks/messages.rake in mumuki-laboratory-9.6.0

@@ -4,14 +4,12 @@
   namespace :messages do
     task listen: :environment do
       logger.info 'Listening to messages'
 
       Mumukit::Nuntius::Consumer.start 'teacher-messages', 'teacher-messages' do |_delivery_info, _properties, body|
-        begin
-          Message.import_from_resource_h!(body)
-        rescue ActiveRecord::RecordInvalid => e
-          logger.info e
-        end
+        ApplicationRecord.with_pg_retry { Message.import_from_resource_h!(body) }
+      rescue ActiveRecord::RecordInvalid => e
+        logger.info e
       end
     end
   end
 end