a message queue by redis streams. Supports Redis >= 5.0.0 and (Node.js >= 8).
Quick Start
Install
$ npm install redis-queue-stream
Basic Usage
const redisQueue = ;const RedisQ = config option;RedisQ;const message = RedisQ;RedisQ;
Andvance
const EventEmitter = EventEmitter;const redisEvent = ;const redisQueue = RedisQueue;const RedisQ = config option;RedisQ;// enqueue redisEvent; redisEvent;
option
queueNames: 'send' 'notify' // all queueName maxlen:number // queue length , default 1000000 groupName:string // default Queue expiryTime:number // outtime,default 15 munites pendingCount: number // retry times,default 2 times ```## Configuration **Single Client** ```javascript config = port: 6379 // porthost: '127.0.0.1' // hostpassword: 'auth'db: 0
Multi Clients
config = foo: // instanceName. See below port: 6379 // Redis port host: '127.0.0.1' // Redis host password: 'auth' db: 0 bar: port: 6379 host: '127.0.0.1' password: 'auth' db: 1 ;
Sentinel
config = sentinels: // Sentinel instances port: 26379 // Sentinel port host: '127.0.0.1' // Sentinel host name: 'mymaster' // Master name password: 'auth' db: 0;
Cluster
config = cluster: true nodes: host: '127.0.0.1' port: '6379' family: 'user' password: 'password' db: 'db' host: '127.0.0.1' port: '6380' family: 'user' password: 'password' db: 'db' ;
Questions & Suggestions
Please open an issue here.