You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Hello, I'm trying to use BullBoardModule with a very specific case.
Basically,
instead of registering a queue with the default BullModule.registerQueue I'm doing something like this
BullModule.registerQueueAsync({imports: [AppModule],useFactory: async(appService: AppService)=>{// Logic to determine the number of logged-in credentialsconstloggedInCount=awaitappService.onModuleInit();// Use loggedInCount to determine concurrency, for example:constconcurrency=Math.max(1,loggedInCount);// Ensure a minimum concurrency of 1return{name: 'main_queue',processors: [{concurrency: concurrency,path: join(__dirname,'processors/main_queue.processor.js'),},],};},inject: [AppService],}),BullBoardModule.forFeature({name: 'main_queue',adapter: BullMQAdapter,}),
The problem I think is that BullBoardModule tries to start up before the queue is actually registered throwing this error
throw new unknown_element_exception_1.UnknownElementException(this.getInstanceNameByToken(token));
^
Error: Nest could not find BullQueue_main_queue element (this provider does not exist in the current context)
Any suggestion on how to fix it? I don't see an async mode, is it not supported?
The text was updated successfully, but these errors were encountered:
Hi, thank you for reporting this issue,
I'm not an expert with Nest.js... (maybe I should become one)
Bull-board, the core do supports async addition /removal of queues...
Hello, I'm trying to use BullBoardModule with a very specific case.
Basically,
instead of registering a queue with the default
BullModule.registerQueue
I'm doing something like thisThe problem I think is that BullBoardModule tries to start up before the queue is actually registered throwing this error
Any suggestion on how to fix it? I don't see an async mode, is it not supported?
The text was updated successfully, but these errors were encountered: