From 05f45a5f7219681a8ec7a0084eac2eb0d0827d33 Mon Sep 17 00:00:00 2001
From: Zdravko Iliev <zdravko.iliev@vereign.com>
Date: Wed, 16 Aug 2023 12:29:31 +0300
Subject: [PATCH] fix: handling stream if already exists
---
apps/agent/README.md | 2 +-
libs/nats/src/base.nats.service.ts | 4 ++++
2 files changed, 5 insertions(+), 1 deletion(-)
diff --git a/apps/agent/README.md b/apps/agent/README.md
index 63a0c611..4ac3348f 100644
--- a/apps/agent/README.md
+++ b/apps/agent/README.md
@@ -1,4 +1,4 @@
-# OCM ENGINE - AGENT
+# OCM ENGINE - AGENT
Agent service is a wrapper around @ocm-engine/askar library.
diff --git a/libs/nats/src/base.nats.service.ts b/libs/nats/src/base.nats.service.ts
index b57c48c5..c0517cff 100644
--- a/libs/nats/src/base.nats.service.ts
+++ b/libs/nats/src/base.nats.service.ts
@@ -75,6 +75,10 @@ export class NatsBaseService {
this.logger.error(
`Failed to connect to NATS, retrying...${error.message}`,
);
+
+ throw new Error(
+ `Failed to connect to NATS, retrying...${error.message}`,
+ );
},
},
);
--
GitLab