From ccd037404cc2338ce2c642a280ea28c346b55e2b Mon Sep 17 00:00:00 2001
From: snowgitea <haoyuexc100@outlook.com>
Date: Wed, 1 Jul 2026 17:56:34 +0800
Subject: [PATCH] chore: src/modules/demo/queue/single.ts

---
 src/modules/demo/queue/single.ts | 20 ++++++++++++++++++++
 1 file changed, 20 insertions(+)
 create mode 100644 src/modules/demo/queue/single.ts

diff --git a/src/modules/demo/queue/single.ts b/src/modules/demo/queue/single.ts
new file mode 100644
index 0000000..c26f746
--- /dev/null
+++ b/src/modules/demo/queue/single.ts
@@ -0,0 +1,20 @@
+import { BaseCoolQueue, CoolQueue } from '@cool-midway/task';
+import { IMidwayApplication } from '@midwayjs/core';
+import { App } from '@midwayjs/core';
+
+/**
+ * 单例队列，cluster 或 集群模式下 只会有一个实例消费数据
+ */
+@CoolQueue({ type: 'single' })
+export class DemoSingleQueue extends BaseCoolQueue {
+  @App()
+  app: IMidwayApplication;
+
+  async data(job: any, done: any): Promise<void> {
+    // 这边可以执行定时任务具体的业务或队列的业务
+    console.log('数据', job.data);
+    // 抛出错误 可以让队列重试，默认重试5次
+    //throw new Error('错误');
+    done();
+  }
+}