跳到主要内容

Queue

Queue可以发送消息队列,可以让任务在后台按顺序运行。

使用

import { Queue } from '@giteeteam/apps-api';

// global代表key是否全局唯一,用于跨应用访问
const queue = new Queue({ key: 'queue-name', global: false });

// define your data
const payloadData = {};
await queue.push(payloadData);

// 可以延迟5秒执行
await queue.push(payloadData, { delayInSeconds: 5 })

事件的消费

可以使用Consumer接收事件。