amqplib-scheduler

Easy messages scheduling with amqplib.

This library is based on purposeindustries/node-amqp-schedule ported to use with the amqplib AMQP client library.

Install

npm install amqplib-scheduler

Use with squaremo/amqp.node.

Usage

var amqp	  = require('amqplib/callback_api');
var scheduler = require('amqplib-scheduler');
 
//A stablished amqp connection in needed
amqp.connect(function (err, conn) {
  if (err !== null) return bail(err);
 
//Scheduler initialization
  var schedule = scheduler(conn, {prefix: 'qPrefix', separator: '.'});
 
  var date = new Date(Date.now() + 20000);
  schedule('dlExchange', 'dlxRoute', { foobar: '30s ' + new Date()}, 30000, cb);
  schedule('dlExchange', 'dlxRoute', { foobar: '@ ' + date }, date, cb);
}

Options

the scheduler initialization accepts a second optional parameter (options) :

{
    prefix: 	[temp queue name prefix, defaults to 'schedule'],
  	separator: 	[temp queue name separator, defaults to '.'],
    threshold: 	[temp queue expires after delay + threshold, defaults to 10000]
}