require 'eventmachine'
require 'em-jack'
 
EM.run {
	@queue = EMJack::Connection.new
 
	# Each job will make an event to reserve and wait for a new job to come in
	@queue.each_job do |job|
		puts "Got job #{job.jobid}"
 
		if process(job)
			@queue.delete(job)
		else
			# failed to process...
			@queue.release(job) # puts the job back on the queue to be worked on again
		end
	end
 
	def process(job)
		puts "yea...."
	end
}