0.0.2 • Published 6 years ago
irajs-queue v0.0.2
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 = require('irajs-queue')
const queue = new Queue({
name: 'ira-one-job'
})
const data = {
x: 'foo',
y: 'bar'
}
const send = async () => {
await queue.send(data)
console.log(`job has saved`)
}
send()
queue.listen(async (job) => {
console.log(`received job: `, job.id)
console.log(`received job data: `, job.data)
})
PS. 参考 examples 三个例子,普通任务、定时或延时任务
LICENSE
MIT