mq

gistfile1.txt

imports
HttpModule
BullModule.forRootAsync({
    imports: [ConfigModule],
      useFactory: async (configService: ConfigService) => {
        const connection = configService.get('redisconnection');
        return {
          connection: connection,
        }
      },
      inject: [ConfigService],
    }),

 BullModule.registerQueue({
      name: Queues.,
    }),


 BullBoardModule.forRoot({
      route: '/queues',
      adapter: ExpressAdapter // Or FastifyAdapter from `@bull-board/fastify`
    }),
    BullBoardModule.forFeature({
      name: Queues,
      adapter: BullMQAdapter, //or use BullAdapter if you're using bull instead of bullMQ
    }),

providers
{
      provide:  Consumer,
      useFactory: (configService: ConfigService, pm:  ManagerService) => {
        const mqEnabled = configService.get('mqEnabled');
        return mqEnabled ? new Consumer(pm, configService) : null;
      },
      inject: [ConfigService, ProxyManagerService],
    }