fix(SqsService): getQueueInfo method return the correct consumer inst…

…ance (#77)
ssut · Apr 20, 2024 · 7292ce4 · 7292ce4
1 parent 72cb675
commit 7292ce4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/sqs.service.ts b/lib/sqs.service.ts
@@ -99,7 +99,7 @@ export class SqsService implements OnModuleInit, OnModuleDestroy {
       throw new Error(`Consumer/Producer does not exist: ${name}`);
     }
 
-    const { sqs, queueUrl } = (this.consumers.get(name) ?? this.producers.get(name)) as {
+    const { sqs, queueUrl } = (this.consumers.get(name).instance ?? this.producers.get(name)) as {
       sqs: SQSClient;
       queueUrl: string;
     };