UpRingPubSub
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.
Install
npm i upring-pubsub --save
Usage
const upring = base: processargv hashring: joinTimeout: 200 upring var count = 0 upring
API
new UpRingPubSub(opts)
See MQEmitter for the actual API.
Acknowledgements
This project is kindly sponsored by nearForm.
License
MIT