rabbitmq-stream-rust-client
rabbitmq-stream-rust-client copied to clipboard
Introduce a smart publisher
The client interface has to be something like:
producer.send(message)
Internally the producer must :
- [ ] Aggregate the messages based on batch-size
- [ ] split the messages based on frame-size
- [ ] send the buffer after a configurable timeout ( default 100 ms)
Related to https://github.com/rabbitmq/rabbitmq-stream-rust-client/issues/85