Examples of com.surftools.BeanstalkClient.Client.touch()

com.surftools.BeanstalkClient.Client.touch()

The "touch" command allows a worker to request more time to work on a job. This is useful for jobs that potentially take a long time, but you still want the benefits of a TTR pulling a job away from an unresponsive worker. A worker may periodically tell the server that it's still alive and processing a job (e.g. it may do this on DEADLINE_SOON). The command postpones the auto release of a reserved job until TTR seconds from when the command is issued. @param jobId is the ID of a job reserved by the current connection. @return true if touched ok, false otherwise

    String srcString = "testTouch";
    int timeoutSeconds = 2;


    // nothing to touch
    boolean ok = false;
    ok = client.touch(0);
    assertFalse(ok);


    // producer
    client.useTube((String) tubeNames[1]);
    long jobId = client.put(65536, 0, timeoutSeconds, srcString.getBytes());

    client.useTube((String) tubeNames[1]);
    long jobId = client.put(65536, 0, timeoutSeconds, srcString.getBytes());
    assertTrue(jobId > 0);


    // we haven't reserved, so we can't touch
    ok = client.touch(jobId);
    assertFalse(ok);


    // reserve the job
    Job job = client.reserve(null);
    assertNotNull(job);

      job = client.reserve(2 * timeoutSeconds);
      fail("expected DEADLINE_SOON");
    } catch (BeanstalkException be) {
      String message = be.getMessage();
      assertEquals("DEADLINE_SOON", message);
      ok = client.touch(jobId);
      assertTrue(ok);
    } catch (Exception e) {
      fail("caught exception: " + e.getMessage());
    }

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.