namespace :classroom do
namespace :messages do task listen: :environment do Mumukit::Nuntius::Logger.info 'Listening to student messages' Mumukit::Nuntius::Consumer.negligent_start! 'student-messages' do |body| begin Mumukit::Nuntius::Logger.info "Processing message #{body}" Mumuki::Classroom::Message.import_from_json!(body).try do |assignment| Mumuki::Classroom::Notification.import_from_json! 'Mumuki::Classroom::Message', assignment end rescue => e Mumukit::Nuntius::Logger.warn "Mumuki::Classroom::Message failed #{e}. body was: #{body}" end end end end
end