WIP: Shared subscriptions

moscajs / aedes-persistence

In-memory implementation of an Aedes persistence, with abstract tests

MIT License

13 stars 22 forks source link

WIP: Shared subscriptions #49

Open robertsLando opened 4 years ago

robertsLando commented 4 years ago

To use with aedes https://github.com/moscajs/aedes/pull/449

getlarge commented 3 years ago

@robertsLando Is there anyway i can help you on that one ?

robertsLando commented 3 years ago

@getlarge Last time I tried I had give up as I wasn't sure this was the correct way to implement this feature. I would like some thoughts on this and https://github.com/moscajs/aedes/pull/449 by @mcollina

mcollina commented 3 years ago

This requires implementing an equivalent of mqemitter for the shared work queue, or adding that same concept there.