Sha256: 1b925cdb93d770fe78803f36646698357d0ed1c2847624056e0fcb94499f50f7
Contents?: true
Size: 393 Bytes
Versions: 39
Compression:
Stored size: 393 Bytes
Contents
logger = Mumukit::Nuntius::Logger
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_json!(body)
rescue ActiveRecord::RecordInvalid => e
logger.info e
end
end
end
end
Version data entries
39 entries across 39 versions & 1 rubygems