fix(): support processors registered with useFactory/useValue

Closes #691
nestjs · Oct 15, 2021 · 4420873 · 4420873
1 parent 26c1606
commit 4420873
Showing 1 changed file with 9 additions and 2 deletions.
diff --git a/lib/bull.explorer.ts b/lib/bull.explorer.ts
@@ -31,15 +31,22 @@ export class BullExplorer implements OnModuleInit {
     const providers: InstanceWrapper[] = this.discoveryService
       .getProviders()
       .filter((wrapper: InstanceWrapper) =>
-        this.metadataAccessor.isQueueComponent(wrapper.metatype),
+        this.metadataAccessor.isQueueComponent(
+          wrapper.inject || !wrapper.metatype
+            ? wrapper.instance?.constructor
+            : wrapper.metatype,
+        ),
       );
 
     providers.forEach((wrapper: InstanceWrapper) => {
       const { instance, metatype } = wrapper;
       const isRequestScoped = !wrapper.isDependencyTreeStatic();
       const {
         name: queueName,
-      } = this.metadataAccessor.getQueueComponentMetadata(metatype);
+      } =
+        this.metadataAccessor.getQueueComponentMetadata(
+          instance.constructor || metatype,
+        );
 
       const queueToken = getQueueToken(queueName);
       const bullQueue = this.getQueue(queueToken, queueName);