Touch support.

beanstalk/job.py

@@ -113,6 +113,17 @@ def Finish(self):
         else:
             return True
 
+    @honorimmutable
+    def Touch(self):
+        try:
+            self.conn.touch(self.id)
+        except errors.NotFound:
+            return False
+        except:
+            raise
+        else:
+            return True
+
     @honorimmutable
     def Bury(self, newpri = 0):
         if newpri:

beanstalk/protohandler.py

@@ -306,6 +306,19 @@ def process_kick(bound=10):
     """
     return 'kick %s\r\n' % (bound,)
 
+@interaction(ok='TOUCHED')
+def process_touch(jid):
+    """
+    touch
+        send:
+            touch <job>
+
+        return:
+            TOUCHED
+            NOT_FOUND
+    """
+    return 'touch %s\r\n' % (jid,)
+
 @interaction(ok='OK', ok_args=['bytes'], has_data=True, parse=yaml.load)
 def process_stats():
     """

examples/simple_clients.py

@@ -20,6 +20,7 @@ def consumer_main(connection):
     while True:
         j = connection.reserve()
         print 'got job! job is: %s' % j.data
+        j.Touch()
         j.Finish()
 
 def main():

examples/twisted_consumer.py

@@ -11,6 +11,7 @@
 
 def executor(bs, jobdata):
     print "Running job %s" % `jobdata`
+    bs.touch(jobdata['jid'])
     bs.delete(jobdata['jid'])
 
 def error_handler(e):

tests/test_Proto.py

@@ -37,6 +37,13 @@
             ('DELETED\r\n',{'state':'ok'})
         ]
     ],
+    [
+        ('process_touch', (185,)),
+        'touch 185\r\n',
+        [
+            ('TOUCHED\r\n',{'state':'ok'})
+        ]
+    ],
     [
         ('process_release', (33,22,17)),
         'release 33 22 17\r\n',