This project allows consuming messages from queues by connecting to RabbitMQ. Different services defined based on the type of the queue are used to consume a message from the queue. For example, we have SMS and email queues, and we can consume them simultaneously by defining consumer functions.
- Make sure Node.js is installed.
- Make sure RabbitMQ is installed.
- (Optional) Make sure MongoDB is installed.
-
Open your terminal and enter the following command to clone a copy of this project:
git clone https://github.com/0x178F/node-consumer.git
-
Go to the project directory:
cd node-consumer -
Run the following command to install the required dependencies:
yarn install
Settings can be configured via configuration files under the config folder. Edit the relevant files to make the desired configurations. The queue names and the functions they should call are defined in enum/queues.js for easy configuration.
You can start the application by running the following command:
yarn devNOTE: If you are deploying in a production environment, there is a docker-compose.yml file in the project.
When the project is successfully started, it starts consuming messages from RabbitMQ and performs the related operations. It consumes messages in the specified functions depending on the queue type.
- Message Consumption: Connects to RabbitMQ and consumes messages from queues.
- Delayed Message Publishing : Publishes delayed messages to a RabbitMQ queue and republishes them to the specified queue after a configurable delay.
- Error Handling: In case of an error, messages can be retried a specified number of times according to the configuration. When the retry limit is exceeded, faulty messages are added to the error queue.
- Graceful Shutdown: Can be gracefully terminated, allowing the current processes to complete and handle the messages waiting to be consumed from RabbitMQ.
- Health Check: Can check the health status of the application and determine if the project is healthy.