irajs-queue
基于 bee-queue 封装一个简单的业务场景
快速开始
npm i irajs-queue
Queue(opts, beeOpts)
opts
- name: 必填, 队列名称
- delayUntil: number | date | timestamp: 选填,只用于延时任务或定时任务
- retry: Object, 重试机制,默认是 6 次,每次 1s * 2 递增。
queue 实例化
-
async send(data, opts)
- data: 数据, Object
- opts: retry: {}, id: string, delayUntil: 覆盖默认的 delayUntil
-
async listen (...generatorFn)
const Queue = const queue = name: 'ira-one-job' const data = x: 'foo' y: 'bar' const send = async { await queue console} queue
PS. 参考 examples 三个例子,普通任务、定时或延时任务
LICENSE
MIT