QueueRedis

QueueRedis

QueueRedis

Constructor

new QueueRedis(options)

Parameters:
Name Type Description
options Object

Queue configuration

Properties
Name Type Description
url String | Boolean

Redis database URL

Source:
See:
Example
const QueueRedis = require('QueueRedis');

const queue = new QueueRedis({ url: true });

queue
.connect()
.then(() => {
  queue.on('task', message => {
    console.log(message);
  });
  queue.emit('task', 'A coffee please !');
});

Extends

Methods

close() → {QueueRedis}

Close the RX / TX channels.

Source:
Returns:
  • The queue to be closed
Type
QueueRedis

connect() → {Promise}

Connect the Redis queue.

Overrides:
Source:
Returns:
  • True when connected
Type
Promise

emit() → {QueueRedis}

Emit a new message to the queue.

Source:
Returns:
  • The queue to be closed
Type
QueueRedis

on() → {QueueRedis}

Listen to new messages emitted from the queue.

Source:
Returns:
  • The queue to be closed
Type
QueueRedis