| 156 | const executionOrder: number[] = []; |
| 157 | |
| 158 | @Processor('priorityTask') |
| 159 | class PriorityTask implements IProcessor { |
| 160 | |
| 161 | async execute(params: { priority: number }): Promise<void> { |
| 162 | executionOrder.push(params.priority); |
| 163 | } |
| 164 | } |
| 165 | |
| 166 | const app = await createLightApp({ |
| 167 | imports: [bullmq], |
nothing calls this directly
no test coverage detected