pkieltyka (owner)

Revisions

gist: 208631 Download_button fork
public
Public Clone URL: git://gist.github.com/208631.git
Embed All Files: show embed
Ruby #
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
# Lil bit of sugar for EMJack::Connection
    def next_job(&block)
      work = Proc.new do
        r = reserve
        
        r.callback do |job|
          block.call(job)
          EM.next_tick { work.call }
        end
      end
 
      work.call
    end
 
# Usage:
 
require 'eventmachine'
require 'em-jack'
 
EM::run do
    jack = EMJack::Connection.new
 
    jack.next_job do |job|
        puts "Got job ##{job.jobid}: #{job}"
    
        r = beanstalk.delete(job)
        r.callback { puts "** Deleted #{job}" }
    end
end