Skip to content
This repository

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
tree: cebe16248e

Fetching latest commit…

Octocat-spinner-32-eaf2f5

Cannot retrieve the latest commit at this time

Octocat-spinner-32 docs
Octocat-spinner-32 lib
Octocat-spinner-32 tests
Octocat-spinner-32 LICENSE make npm compatible, add license March 03, 2011
Octocat-spinner-32 README.md
Octocat-spinner-32 package.json
README.md

A Beanstalk client utilising node.js Tested for beanstalkd 1.4.6

INSTALL

npm install nodestalker

USAGE

Simple usage example:

var bs = require('nodestalker'),
    client = bs.Client();

client.use('default').onSuccess(function(data) {
  console.log(data);

  client.put('my job').onSuccess(function(data) {
    console.log(data);
    client.disconnect();
  });
});

How do I reserve multiple items?

Each client basically represents one open socket to beanstalkd. Each command call just pumps one command into that socket, which then expects a corresponding return.

The server should maintain the state of the socket. However, reserve (or reserve with timeout) will only pull one job. You should then be able to reserve again on the same socket with the state of watch and ignore still preserved by the server.

Probably the most common usage scenario:

var bs = require('nodestalker'),
    client = bs.Client(),
    tube = 'test_tube';

client.watch(tube).onSuccess(function(data) {
    function resJob() {
        client.reserve().onSuccess(function(job) {
            console.log('reserved', job);

            client.deleteJob(job.id).onSuccess(function(del_msg) {
                console.log('deleted', job);
                console.log('message', del_msg);
                resJob();
            });
        });
    }

    resJob();
});

If you want to do this fully in a fully asynchronous way, because there's a blocking process happening otherwise, you'll have to work with multiple sockets. This means that you'll have to repeat watch and ignore commands for each socket.

var bs = require('nodestalker'),
    tube = 'test_tube';

function processJob(job, callback) {
    // doing something really expensive
    console.log('processing...');
    setTimeout(function() {
        callback();
    }, 1000);
}

function resJob() {
    var client = bs.Client();

    client.watch(tube).onSuccess(function(data) {
        client.reserve().onSuccess(function(job) {
            console.log('received job:', job);
            resJob();

            processJob(job, function() {
                client.deleteJob(job.id).onSuccess(function(del_msg) {
                    console.log('deleted', job);
                    console.log(del_msg);
                    client.disconnect();
                });
                console.log('processed', job);
            });
        });
    });
}

resJob();

DOCUMENTATION

Annotated source in the docs folder

TESTING

Also there are some tests now. Please make sure beanstalkd is running on the default settings.

To run all tests:

find tests/ | grep .js | xargs -n1 node

CREDIT

Depends on the yaml package by visionmedia.

https://github.com/visionmedia/js-yaml

Thanks to people that took time to fix some things.

aahoughton

Something went wrong with that request. Please try again.