[Improvement]: Enhancing Concurrency Control and Throttling Mechanisms for RabbitMQ Proxy Service Listener

[sajith-madhusanka]

Description

As per the current implementation, we can't control the concurrency of the RabbitMQ Proxy Service Listener, which leads to overhead in the rest of the message flow. We need to improve the RabbitMQ Proxy Service Listener to control the message retrieval process.

Describe your problem(s)

Let's assume the message flow includes logic to process messages received from RabbitMQ via the RabbitMQ Proxy Service Listener and insert them into a database. With high concurrency in the message-receiving flow, it may become challenging to handle the data insertion process, potentially leading to a crash in the flow.

Describe your solution(s)

If we can configure the RabbitMQ Proxy Service Listener to control the message retrieval rate, we can overcome the issue mentioned above.

Related issue(s) (optional)

No response

Suggested label(s) (optional)

No response

Suggested assignee(s) (optional)

No response