Pub/Sub messaging with NATS

nats-pubsub.js

const NATS = require("nats");
const nc = new NATS({ url: "nats://localhost:4222", json: true });

nc.on("connect", c => console.log("connected!"));
nc.on("error", err => console.log(err.message));

// time.* というSubjectを購読
nc.subscribe("time.*", msg => {
  console.log(msg);
  nc.close();
});

// time.jp というSubjectに配信
nc.publishe("time.jp", { "publishedAt": new Date().toISOString() });