Contents

$:.unshift ::File.dirname(__FILE__) + '/../lib'

require 'rubygems'
require 'raemon'
require 'em-jack'

class EventedJobWorker
  include Raemon::Worker
  
  def start
    logger.info "=> Starting worker #{Process.pid}"
  end
  
  def stop
    logger.info "=> Stopping worker #{Process.pid}"
    
    EM.stop_event_loop if EM.reactor_running?
    exit
  end
  
  def execute
    EventMachine.run do
      @queue = EMJack::Connection.new
      
      @queue.each_job(5) do |job|        
        logger.info "(#{Process.ppid}:#{Process.pid}) got job: #{job.inspect}"
        # process(job)
        @queue.delete(job)
        
        stop if shutting_down?
      end
      
      @queue.on_error do |error|
        case error
        when :timed_out
          # We use the reserve timeout to check if we should shutdown
          stop if shutting_down?
        else
          logger.error error.to_s
        end
      end
    end
  end

end

Raemon::Master.startup 2, EventedJobWorker

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
raemon-0.1.2	examples/evented.rb
raemon-0.1.1	examples/evented.rb