From a0342fee39cfc58fd5d904f87fc2749776490bf5 Mon Sep 17 00:00:00 2001
From: Zdravko Iliev <zdravko.iliev@vereign.com>
Date: Wed, 16 Aug 2023 12:08:28 +0300
Subject: [PATCH] fix: if the stream exists get it
---
libs/nats/src/consumer.nats.service.ts | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/libs/nats/src/consumer.nats.service.ts b/libs/nats/src/consumer.nats.service.ts
index 88157ea1..8cef00f8 100644
--- a/libs/nats/src/consumer.nats.service.ts
+++ b/libs/nats/src/consumer.nats.service.ts
@@ -38,7 +38,7 @@ export class ConsumerService extends NatsBaseService {
return this.jsClient.consumers.get(stream, consumerConfig.name);
} catch (error) {
- if (error instanceof NatsError && error.code === "409") {
+ if (error instanceof NatsError && error.api_error?.err_code === 10065) {
this.logger.log("Stream already exists");
return this.jsClient.consumers.get(stream, consumerConfig.name);
}
--
GitLab