Contents

module Magent
  class Processor
    attr_reader :actor

    def initialize(actor)
      @actor = actor

      @actor.class.actions.each do |action|
        if !@actor.respond_to?(action)
          raise ArgumentError, "action '#{action}' is not defined"
        end
      end
    end

    def run!
      delay = 0
      loop do
        method, payload = @actor.class.channel.dequeue

        if method.nil?
          delay += 0.1 if delay <= 5
        else
          delay = 0
          $stderr.puts "#{@actor.class}##{method}(#{payload.inspect})"
          @actor.send(method, payload) # TODO: what if method is not defined?
        end

        sleep delay
      end
    end
  end #Processor
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
magent-0.0.1	lib/magent/processor.rb