Skip to content

Commit 7292ce4

Browse files
authored
fix(SqsService): getQueueInfo method return the correct consumer instance (#77)
1 parent 72cb675 commit 7292ce4

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

lib/sqs.service.ts

+1-1
Original file line numberDiff line numberDiff line change
@@ -99,7 +99,7 @@ export class SqsService implements OnModuleInit, OnModuleDestroy {
9999
throw new Error(`Consumer/Producer does not exist: ${name}`);
100100
}
101101

102-
const { sqs, queueUrl } = (this.consumers.get(name) ?? this.producers.get(name)) as {
102+
const { sqs, queueUrl } = (this.consumers.get(name).instance ?? this.producers.get(name)) as {
103103
sqs: SQSClient;
104104
queueUrl: string;
105105
};

0 commit comments

Comments
 (0)