Accepted answer

Akka should be able to support that - .
You can also check out kestrel -


You can also try simple java PubSub system based on Redis with Redisson lib


You should definitely take a look at Akka Streams. They support bounded buffers in the most elegant way, using the backpressure.

Related Query

More Query from same tag