queues queue.ts

20% Statements 1/5

0% Branches 0/2

0% Functions 0/1

20% Lines 1/5

Press n or j to go to the next uncovered block, b, p or k for the previous block.


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16  
 
 
 
 
1x
 
 
 
 
 
 
 
 
 
  import { Queue } from "bullmq"
 
import { env } from "../config"
import { QueueArgs } from "./queueArgs"
 
let queue: Queue<QueueArgs> | null = null
 
export async function getQueue(): Promise<Queue<QueueArgs>> {
  if (queue) {
    return queue
  }
 
  queue = new Queue("manager", { connection: env.redisConnection })
  return queue
}