Contents

module Writefully
  module Tools
    class Dispatcher
      include Celluloid

      attr_reader :job

      def initialize
        every 1.second do 
          async.heartbeat
        end
      end

      def get_job_data
        Writefully.redis.with { |c| c.lpop 'jobs' }
      end

      def heartbeat
        data = get_job_data
        if data
          @job      = Marshal.load(data)
          run_job if job_valid?
        end
      end

      def run_job
        if    retry_valid?   then retry_job
        elsif job_valid?     then dispatch
        end
      end

      def dispatch
        Celluloid::Actor[job[:worker]].perform(job[:message])
      end

      def retry_job
        Celluloid::Actor[:retryer].retry(job)
      end

      def is_retry?
        job_valid? and job[:message].has_key?(:tries) and job[:message].has_key?(:run)
      end

      def job_valid?
        job.has_key?(:worker) and job.has_key?(:message)
      end

      def retry_valid?
        is_retry? and (job[:message][:run] == false)
      end

    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
writefully-0.8.2	lib/writefully/tools/dispatcher.rb
writefully-0.8.1	lib/writefully/tools/dispatcher.rb
writefully-0.8.0	lib/writefully/tools/dispatcher.rb
writefully-0.7.1	lib/writefully/tools/dispatcher.rb
writefully-0.6.12	lib/writefully/tools/dispatcher.rb
writefully-0.6.11	lib/writefully/tools/dispatcher.rb
writefully-0.6.10	lib/writefully/tools/dispatcher.rb