1 parent 30a40d8 commit e383a4dCopy full SHA for e383a4d
1 file changed
api/src/services/QueueManager.ts
@@ -30,13 +30,13 @@ class QueueManager {
30
}
31
32
protected getQueue(queueName: string = ""): Queue {
33
- return new Queue(queueName ?? this.config.redisDefaultQueueName, this.queueBaseOptions);
+ return new Queue(queueName || this.config.redisDefaultQueueName, this.queueBaseOptions);
34
35
36
public getWorker(callback: Processor, queueName: string = ""): Worker {
37
const options: WorkerOptions = this.queueBaseOptions;
38
options.lockDuration = this.config.redisLockDuration;
39
- return new Worker(queueName ?? this.config.redisDefaultQueueName, callback, options);
+ return new Worker(queueName || this.config.redisDefaultQueueName, callback, options);
40
41
42
protected getQueueNameForJob(jobName: string): string {
0 commit comments