Sha256: 4f79c0f459f2a54355f90c7640079e147811eede6449413e948daabecbc6aa4e

Contents?: true

Size: 452 Bytes

Versions: 91

Compression:

Stored size: 452 Bytes

Contents

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

Version data entries

91 entries across 91 versions & 1 rubygems

Version Path
mumuki-laboratory-9.5.1 lib/tasks/messages.rake
mumuki-laboratory-9.5.0 lib/tasks/messages.rake
mumuki-laboratory-9.4.1 lib/tasks/messages.rake
mumuki-laboratory-9.4.0 lib/tasks/messages.rake
mumuki-laboratory-9.3.1 lib/tasks/messages.rake
mumuki-laboratory-9.3.0 lib/tasks/messages.rake
mumuki-laboratory-9.2.0 lib/tasks/messages.rake
mumuki-laboratory-9.1.3 lib/tasks/messages.rake
mumuki-laboratory-9.1.2 lib/tasks/messages.rake
mumuki-laboratory-9.1.1 lib/tasks/messages.rake
mumuki-laboratory-9.1.0 lib/tasks/messages.rake
mumuki-laboratory-9.0.6 lib/tasks/messages.rake
mumuki-laboratory-9.0.5 lib/tasks/messages.rake
mumuki-laboratory-9.0.4 lib/tasks/messages.rake
mumuki-laboratory-9.0.3 lib/tasks/messages.rake
mumuki-laboratory-9.0.2 lib/tasks/messages.rake
mumuki-laboratory-9.0.1 lib/tasks/messages.rake
mumuki-laboratory-9.0.0 lib/tasks/messages.rake
mumuki-laboratory-8.6.1 lib/tasks/messages.rake
mumuki-laboratory-8.6.0 lib/tasks/messages.rake