logger = Mumukit::Nuntius::Logger

namespace :laboratory do

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|
      ApplicationRecord.with_pg_retry { Message.import_from_resource_h!(body) }
    rescue ActiveRecord::RecordInvalid => e
      logger.info e
    end
  end
end

end