PubSub system built on top of an UpRing consistent hashring.
You will get a pubsub system that is consistently available, so it can lose messages when the topology changes.
However, it is massively scalable.
npm i upring-pubsub --save
const upring =base: processargvhashring:joinTimeout: 200upringvar count = 0upring
See MQEmitter for the actual API.
This project is kindly sponsored by nearForm.