@@ -7,24 +7,24 @@ job. It won't eat up any CPU on the client or server side as it waits either. Also, this works if you have multiple workers connected to beanstalkd taking jobs off the queue (it will distribute). See example below: -EM.run { - jack = EMJack::Connection.new - - jack.each_job do |job| - puts "Got job ##{job.jobid}: #{job}" - - if process(job) - r = jack.delete(job) - r.callback { puts "*Deleted #{job}*" } - else + EM.run { + jack = EMJack::Connection.new + + jack.each_job do |job| + puts "Got job ##{job.jobid}: #{job}" + + if process(job) + r = jack.delete(job) + r.callback { puts "*Deleted #{job}*" } + else + end end - end + + def process(job) + # Some kind of job processing + end + } - def process(job) - # Some kind of job processing - end -} - # Open source rocks. Enjoy, # Peter README.rdoc 568d7eee8488e999dc94bb26bad1e3a8404465f6 Peter Kieltyka peter.kieltyka@nulayer.com http://github.com/pkieltyka/em-jack/commit/41695f1d09676ba2c4d1217d5e477b02a928fcfa 41695f1d09676ba2c4d1217d5e477b02a928fcfa 2009-10-18T16:48:21-07:00 2009-10-15T06:48:07-07:00 Fix README markup 2c69ae1f5c86783d9d2adae389054f27cb950ebf dj2 dj2@everburning.com