eclipse-vertx / eclipse-vertx/vert.x
Class Gateway EventBus address → BlockingQueue
Open
enhancement
- Dominant language
- Java
- Stars
- 14.7k
- Forks
- 2.1k
- Avg merge
- 2d 7h
- Merged PRs (30d)
- 28
Description
If one need to process Messages from EventBus in batches in blocking code, he has to implement quite complex code with hand-made batch (ArrayList) creation, timer/timeout and blocking code execution.
It would be great to have an alternative implementation of MessageConsumerImpl with less "layers" (aka Gateway Class) for message-batching purposes.
See proof of concept with blazing speed and low memory consumption!
https://github.com/magicprinc/vert.x/commit/3de41f0bb069c230b8fe27987f18a2ecbcad8304
Contributor guide
Assessment
This issue has not been assessed yet.