diff --git a/src/modules/demo/queue/getter.ts b/src/modules/demo/queue/getter.ts new file mode 100644 index 0000000..8da42c9 --- /dev/null +++ b/src/modules/demo/queue/getter.ts @@ -0,0 +1,7 @@ +import { BaseCoolQueue, CoolQueue } from '@cool-midway/task'; + +/** + * 主动消费队列 + */ +@CoolQueue({ type: 'getter' }) +export class DemoGetterQueue extends BaseCoolQueue {}