How to implement an event based consumer which can process max n messages at any given time?
We have a scenario in the application where user uploads a file from UI.
The file along with some metadata is saved to DB.
Currently, we are running a scheduler which will poll the DB every 15 secs to see if any files needs to be processed.
It can process max upto 10 files at a time.