GitHub Sale: sign up for any paid plan this week and pay nothing until January 1, 2009!  [ hide ]

public
Rubygem
Fork of dustin/beanstalk-client-ruby
Description: Ruby client for beanstalkd
Homepage: http://xph.us/software/beanstalkd/
Clone URL: git://github.com/kr/beanstalk-client-ruby.git
Don't try to manipulate a job we don't own.
kr (author)
Sun Jul 20 23:39:35 -0700 2008
commit  8915c23559f81cb88ed1272d54356dd33eb62268
tree    594155256050f750a76b5f7aa6f6afb609ebe924
parent  d49d2424bdaa80e68dd83b11ab1dea723605b91e
...
36
37
38
39
 
40
41
42
43
 
44
45
46
47
48
 
 
 
49
50
51
...
53
54
55
 
56
 
57
58
59
 
60
 
61
62
63
...
36
37
38
 
39
40
41
42
 
43
44
45
46
 
 
47
48
49
50
51
52
...
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
0
@@ -36,16 +36,17 @@ class Beanstalk::Job
0
     (@ybody ||= [begin YAML.load(body) rescue nil end])[0]
0
   end
0
 
0
- def initialize(conn, id, body)
0
+ def initialize(conn, id, body, reserved=true)
0
     @conn = conn
0
     @id = id
0
     @body = body
0
- @deleted = false
0
+ @reserved = reserved
0
   end
0
 
0
   def delete()
0
- @conn.delete(id) if !@deleted
0
- @deleted = true
0
+ return if !@reserved
0
+ @conn.delete(id)
0
+ @reserved = false
0
   end
0
 
0
   def put_back(pri=self.pri, delay=0, ttr=self.ttr)
0
@@ -53,11 +54,15 @@ class Beanstalk::Job
0
   end
0
 
0
   def release(newpri=pri, delay=0)
0
+ return if !@reserved
0
     @conn.release(id, newpri, delay)
0
+ @reserved = false
0
   end
0
 
0
   def bury(newpri=pri)
0
+ return if !@reserved
0
     @conn.bury(id, newpri)
0
+ @reserved = false
0
   end
0
 
0
   def stats()

Comments

    No one has commented yet.