Skip to content
Snippets Groups Projects
Unverified Commit 27bb38c9 authored by Zdravko Iliev's avatar Zdravko Iliev
Browse files

fix: try to update the stream

parent a3f68902
No related branches found
No related tags found
1 merge request!31ci: issuer doesn't see any new connections in GET /connections or GET /connections/:id
Pipeline #64835 passed with stage
in 1 minute and 46 seconds
# OCM ENGINE - AGENT # OCM ENGINE - AGENT
Agent service is a wrapper around @ocm-engine/askar library. Agent service is a wrapper around @ocm-engine/askar library.
......
...@@ -76,10 +76,6 @@ export class NatsBaseService { ...@@ -76,10 +76,6 @@ export class NatsBaseService {
this.logger.error( this.logger.error(
`Failed to connect to NATS, retrying...${error.message}`, `Failed to connect to NATS, retrying...${error.message}`,
); );
throw new Error(
`Failed to connect to NATS, retrying...${error.message}`,
);
}, },
}, },
); );
...@@ -98,7 +94,8 @@ export class NatsBaseService { ...@@ -98,7 +94,8 @@ export class NatsBaseService {
this.logger.log(JSON.stringify(e, null, 2)); this.logger.log(JSON.stringify(e, null, 2));
if (e instanceof NatsError && e.api_error?.err_code === 10065) { if (e instanceof NatsError && e.api_error?.err_code === 10065) {
return await this.jsm.streams.get(sconfig.name); this.logger.log("here ?");
return await this.jsm.streams.update(sconfig.name, sconfig);
} }
throw new Error(`RegisterStream failed.`); throw new Error(`RegisterStream failed.`);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment