rozu-queue
Offline processing queue for rozu webhook server.
Example
var queue = 'rozu' 6379 'localhost'; { process;} ;
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