Package com.trendrr.beanstalk

Examples of com.trendrr.beanstalk.BeanstalkClient.deleteJob()

47
48
49
50
51
52
53
54
55
56
57
    BeanstalkClient client = new BeanstalkClient("localhost", 8010, "example");
    log.info("Putting a job");
    client.put(1l, 0, 5000, "this is some data".getBytes());
    BeanstalkJob job = client.reserve(60);
    log.info("GOt job: " + job);
    client.deleteJob(job);
    client.close(); //closes the connection
  }
 
 
  public static void pooledExample()  throws BeanstalkException {
View Full Code Here
64
65
66
67
68
69
70
71
72
   
    log.info("Putting a job");
    client.put(1l, 0, 5000, "this is some data".getBytes());
    BeanstalkJob job = client.reserve(60);
    log.info("GOt job: " + job);
    client.deleteJob(job);
    client.close();  //returns the connection to the pool
  }
}
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.