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(