|
A 0 dependency, full-featured, battle-tested beanstalk client library.
NOTE
While version is lower thanv1.0.0
the API might change slightly
yarn add @beanstalk/core
import { BeanstalkClient } from '@beanstalk/core';
/**
* Usage: node put.js
*/
async function main() {
const client = new BeanstalkClient();
await client.connect(); // defaults to localhost:11300
const id = await client.put('Hello World');
console.log(`Job created with '${id}'`);
client.quit();
}
main().catch((err) => {
console.error(err.message);
process.exit(1);
});
import { BeanstalkClient } from '@beanstalk/core';
/**
* Usage: node reserve.js > out
*/
async function main() {
const client = new BeanstalkClient();
await client.connect(); // defaults to localhost:11300
await client.watch('my-tube');
await client.ignore('default'); // 'default' is watched by default
// hangs until a job gets ready on 'my-tube'
const [id, payload] = await client.reserve();
console.error(`Job ID: ${id}`);
await new Promise((resolve, reject) => {
process.stdout.write(payload, (err) => err ? reject(err) : resolve());
});
client.quit();
}
main().catch((err) => {
console.error(err.message);
process.exit(1);
});
Generated using TypeDoc