Instead of having a push strategy where manufacturers send messages directly to consumers, you can use a pull strategy where consumers request messages from manufacturers.
To be sure that the answer is almost instantaneous, manufacturers can produce a limited amount of data in advance. When they receive a request, they first send one of the preformed data, then generate a new one.
You can also use Akka actors who provide a limited inbox.
source share