avoidwork/rozu-queue

Offline processing queue for rozu

rozu-queue

Offline processing queue for rozu webhook server.

Example

var queue = require('rozu-queue')('rozu', 6379, 'localhost');

function repeat () {
	process.nextTick(function () {
		queue.process(50).then(function (data) {
			// do something with `data`
			repeat();
		}, function (e) {
			console.error(e.stack);
			repeat();
		});
	});
}

repeat();

API

constructor(channel, port, host)

Takes the redis channel, port & host as parameters, and creates an in RAM queue which can be batched processed with delays, as well as an easy drain.

process(n = 1, delay = 0)

Returns a Promise of the data to be processed.

drain(fn)

Drains the queue and executes an optional Function against the items if provided.

License

Copyright (c) 2015 Jason Mulligan All Rights Reserved