smallrye-reactive-messaging icon indicating copy to clipboard operation
smallrye-reactive-messaging copied to clipboard

Allow multiple consumers per channel for RabbitMQ connector

Open pravussum opened this issue 3 years ago • 1 comments
trafficstars

Currently for each incoming Smallrye messaging channel there is one RabbitMQ consumer created. It would be beneficial to allow the creation of multiple RabbitMQ consumers per channel.

Our use case is the following: We have a high load environment where one RabbitMQ node is not able to process the full load, so our queues are sharded and thus distributed over all RabbitMQ nodes. If there are fewer RabbitMQ consumers than RabbitMQ nodes, not all messages will be fetched.

If each of our clients could be configured to create multiple consumers (greater than the number of RabbitMQ nodes), they would be evenly distributed over all queues, thus all messages could be consumed.

Here is the corresponding code location.

pravussum avatar Apr 08 '22 11:04 pravussum

@pravussum @cescoffier This issue can be closed correct?

kdubb avatar May 28 '22 19:05 kdubb