mahyargdz
20 lines
528 B
TypeScript
Executable File
20 lines
528 B
TypeScript
Executable File
import { SharedBullAsyncConfiguration } from "@nestjs/bullmq";
|
|
import { ConfigService } from "@nestjs/config";
|
|
|
|
export function bullMqConfig(): SharedBullAsyncConfiguration {
|
|
return {
|
|
inject: [ConfigService],
|
|
useFactory: async (configService: ConfigService) => ({
|
|
connection: {
|
|
url: configService.getOrThrow<string>("REDIS_URI"),
|
|
},
|
|
prefix: "danak-console",
|
|
defaultJobOptions: {
|
|
removeOnComplete: false,
|
|
removeOnFail: false,
|
|
attempts: 5,
|
|
},
|
|
}),
|
|
};
|
|
}
|