From 761e7a00765883923d91e9357e22e82f2d0533d4 Mon Sep 17 00:00:00 2001 From: snowgitea Date: Wed, 1 Jul 2026 17:56:33 +0800 Subject: [PATCH] chore: src/modules/demo/queue/comm.ts --- src/modules/demo/queue/comm.ts | 20 ++++++++++++++++++++ 1 file changed, 20 insertions(+) create mode 100644 src/modules/demo/queue/comm.ts diff --git a/src/modules/demo/queue/comm.ts b/src/modules/demo/queue/comm.ts new file mode 100644 index 0000000..5b2f87d --- /dev/null +++ b/src/modules/demo/queue/comm.ts @@ -0,0 +1,20 @@ +import { BaseCoolQueue, CoolQueue } from '@cool-midway/task'; +import { IMidwayApplication } from '@midwayjs/core'; +import { App } from '@midwayjs/core'; + +/** + * 普通队列 + */ +@CoolQueue() +export class DemoCommQueue extends BaseCoolQueue { + @App() + app: IMidwayApplication; + + async data(job: any, done: any): Promise { + // 这边可以执行定时任务具体的业务或队列的业务 + console.log('数据', job.data); + // 抛出错误 可以让队列重试,默认重试5次 + //throw new Error('错误'); + done(); + } +}