@@ -7,23 +7,23 @@ 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 - end - end - - def process(job) - # Some kind of job processing - end - } + 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 + + def process(job) + # Some kind of job processing + end + } # Open source rocks. Enjoy, # Peter README.rdoc 41695f1d09676ba2c4d1217d5e477b02a928fcfa Peter Kieltyka peter.kieltyka@nulayer.com http://github.com/pkieltyka/em-jack/commit/64db1151d6cf62734a9dc4d59657fbfee843501a 64db1151d6cf62734a9dc4d59657fbfee843501a 2009-10-18T16:48:21-07:00 2009-10-15T06:49:46-07:00 Fix README markup, again 34c887061dabf16a9fe01e5d4df378b34bbd4574 dj2 dj2@everburning.com