Contents

module Cloudist
  class Worker
    
    attr_reader :options
    
    def initialize(options)
      @options = options
    end
    
    def log
      Cloudist.log
    end
    
    def job(queue_name, &block)
      q = JobQueue.new(queue_name)
      q.subscribe do |request|
        j = Job.new(request.payload.dup)
        j.instance_eval(&block)
        j.cleanup
      end
    end
    
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
cloudist-0.1.2	lib/cloudist/worker.rb
cloudist-0.1.1	lib/cloudist/worker.rb
cloudist-0.1.0	lib/cloudist/worker.rb
cloudist-0.0.3	lib/cloudist/worker.rb
cloudist-0.0.2	lib/cloudist/worker.rb