6776e073b6
* feat: adding family 6 in uri to configure for both 4 and 6 * feat: adding redis family in websocket config
48 lines
1.4 KiB
TypeScript
48 lines
1.4 KiB
TypeScript
import { Global, Module } from '@nestjs/common';
|
|
import { BullModule } from '@nestjs/bullmq';
|
|
import { EnvironmentService } from '../environment/environment.service';
|
|
import { createRetryStrategy, parseRedisUrl } from '../../common/helpers';
|
|
import { QueueName } from './constants';
|
|
import { BacklinksProcessor } from './processors/backlinks.processor';
|
|
|
|
@Global()
|
|
@Module({
|
|
imports: [
|
|
BullModule.forRootAsync({
|
|
useFactory: (environmentService: EnvironmentService) => {
|
|
const redisConfig = parseRedisUrl(environmentService.getRedisUrl());
|
|
return {
|
|
connection: {
|
|
host: redisConfig.host,
|
|
port: redisConfig.port,
|
|
password: redisConfig.password,
|
|
db: redisConfig.db,
|
|
family: redisConfig.family,
|
|
retryStrategy: createRetryStrategy(),
|
|
},
|
|
defaultJobOptions: {
|
|
attempts: 3,
|
|
backoff: {
|
|
type: 'exponential',
|
|
delay: 10000,
|
|
},
|
|
},
|
|
};
|
|
},
|
|
inject: [EnvironmentService],
|
|
}),
|
|
BullModule.registerQueue({
|
|
name: QueueName.EMAIL_QUEUE,
|
|
}),
|
|
BullModule.registerQueue({
|
|
name: QueueName.ATTACHMENT_QUEUE,
|
|
}),
|
|
BullModule.registerQueue({
|
|
name: QueueName.GENERAL_QUEUE,
|
|
}),
|
|
],
|
|
exports: [BullModule],
|
|
providers: [BacklinksProcessor],
|
|
})
|
|
export class QueueModule {}
|