nzambello/nats-example
1
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

update subject to sessionID as ref

Browse source
This commit is contained in:
Nicola Zambello 2025-08-04 11:32:00 +02:00
parent a8ef4a2bad
commit c9aa5b68c0
Signed by: nzambello
GPG key ID: 0A7E9D12831FAAF9
2 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
client.ts
View file

@ -40,7 +40,7 @@ function askForMessage() {
process.exit(0); process.exit(0);
} }
nc.publish("test", message); nc.publish("sessionID", message);
askForMessage(); askForMessage();
}); });

4
index.ts
View file

@ -10,9 +10,9 @@ console.log(
const nc = await connect({ servers: NATS_SERVER, token: NATS_AUTH_TOKEN }); const nc = await connect({ servers: NATS_SERVER, token: NATS_AUTH_TOKEN });
console.log("Connected to NATS"); 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) { for await (const msg of sub) {
console.log( console.log(