From c9aa5b68c0d9a1d92d26dfc876254f9c27f98e73 Mon Sep 17 00:00:00 2001 From: nzambello Date: Mon, 4 Aug 2025 11:32:00 +0200 Subject: [PATCH] update subject to sessionID as ref --- client.ts | 2 +- index.ts | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/client.ts b/client.ts index 0e8a15e..fb36620 100644 --- a/client.ts +++ b/client.ts @@ -40,7 +40,7 @@ function askForMessage() { process.exit(0); } - nc.publish("test", message); + nc.publish("sessionID", message); askForMessage(); }); diff --git a/index.ts b/index.ts index 80f14eb..1ce1090 100644 --- a/index.ts +++ b/index.ts @@ -10,9 +10,9 @@ console.log( const nc = await connect({ servers: NATS_SERVER, token: NATS_AUTH_TOKEN }); console.log("Connected to NATS"); -const sub = nc.subscribe("test"); +const sub = nc.subscribe("sessionID"); -console.log("Subscribed to [test], waiting for messages...\n"); +console.log("Subscribed to [sessionID], waiting for messages...\n"); for await (const msg of sub) { console.log(