QyuTeam/qyu

# frozen_string_literal: true

require_relative '../config'

class SimpleWorker
  def run
    Qyu::Worker.new do
      callback :execute, :before do
        Qyu.logger.info 'Waiting for task..'
      end

      callback :execute, :after do
        Qyu.logger.info 'Done'
      end

      # Timeout
      timeout 120

      # Payload validation
      validates :times, presence: true, type: :integer

      # Consumes messages from print-hello queue
      work('print-hello') do |task|
        begin
          task.payload['times'].times do |i|
            Qyu.logger.info "#{i + 1}. Hello"
          end
        rescue StandardError => ex
          Qyu.logger.error 'OMG :('
          Qyu.logger.error ex.message
        end
      end
    end
  end
end