From 7292ce48bc437353b709b308674a2924767f536e Mon Sep 17 00:00:00 2001 From: Verdini Date: Sat, 20 Apr 2024 12:43:39 -0300 Subject: [PATCH] fix(SqsService): getQueueInfo method return the correct consumer instance (#77) --- lib/sqs.service.ts | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/sqs.service.ts b/lib/sqs.service.ts index 03c411b..6701c94 100644 --- 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; };