It is near always better to process messages from a message bus/stream in small batches. To add or change the message parameter of the `producer` and `guest` func from single to list would make some sens. An empty-list could be viewed as `flush` notification.