rguiu / bstalkj Goto Github PK

// Create a factory with given configuration
BeanstalkFactory factory = BeanstalkFactory.factory().host("localhost")
												     .port(11300)
												     .connectionTimeout(5000)
												     .tube("dummy_tube")
												     .build();
// fetch the producer
Producer producer = factory.get().producer();
// place job
producer.put(1l, 0, 5000, "this is some data".getBytes());
// print tube stats
System.out.println(producer.tubeStats());

// We can use the default factory, poiting to localhost:11300
BeanstalkFactory factory = BeanstalkFactory.defaultFactory();

Worker worker = factory.get().worker();
BeanstalkJob job = worker.reserve(60).get();

System.out.println("Got job: " + job);

worker.delete(job);
System.out.println(worker.tubeStats());

// Like in non-pooled client we need to configure first or connection
BeanstalkFactory factory = BeanstalkFactory.factory().host("localhost")
												     .port(11300)
												     .connectionTimeout(5000)
												     .tube("another_dummy_tube")
												     .build();

// Optionally we could configure non-default pool parameters
GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig();
poolConfig.setMaxTotal(8);
poolConfig.setMaxIdle(8);

BeanstalkPool pool = new BeanstalkPool(poolConfig, factory);
// If we use default pool configuration we could do:
// BeanstalkPool pool = new BeanstalkPool(factory);
					
try (Producer producer = pool.getResource().producer()) {
	producer.put(1l, 0, 5000, "this is some data".getBytes());
	log.info(producer.tubeStats());
}						 												 

try (Worker worker = pool.getResource().worker()) {
			BeanstalkJob job = worker.reserve(60).get();
			log.info("Got job: " + job);
			worker.delete(job);
}