Constructor
new QueueRedis(options)
Parameters:
| Name | Type | Description | ||||||
|---|---|---|---|---|---|---|---|---|
options |
Object | Queue configuration Properties
|
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