rmq-pub-sub is designed based on the RabbitMQ Pub-Sub functionality. A easier way to call a function named RMQPubStream to Produce any stream and consume by RMQSubStream.
$ npm i rmq-pub-sub
or
$ yarn add rmq-pub-sub
This example shows you how to create microservice and add pub-sub to communicate between services by rmq-pub-sub.
Note: Create NodeJS environment in both service-1 and service-2 and create server using your favourite NodeJS framework.
const RMQPubStream = require('rmq-pub-sub/RMQPubStream');
app.post('/send', async (req, res) => {
const fakeData = {
Name: "Md. Muhtasim Fuad Fahim",
Email: "[email protected]",
};
const produce = await RMQPubStream("FAKE_DATA", fakeData);
console.log("Producer: ", produce);
return res.status(200).send("Done!");
});const RMQSubStream = require('rmq-pub-sub/RMQSubStream');
(async function rmqData() {
await RMQSubStream("FAKE_DATA").then((data) => {
console.log("CONSUME: ", data);
});
})();AMQP_URL = "amqp://localhost"docker run --name rabbitmq -p 5672:5672 rabbitmqNow run the both services in your machine and hit the API: http://localhost:${PORT}/send 🥳
- Fork it 😎
- Create a feature branch:
git checkout -b my-feature - Add your changes:
git add . - Commit your changes:
git commit -m 'My new feature' - Push to the branch:
git push origin my-feature - Submit a pull request
Contributions, issues and features requests are welcome!
📮 Submit PRs to help solve issues or add features
🐛 Find and report issues
🌟 Star the project
- Fork it 😎
- Clone forked repository:
git clone https://github.com/username/forked-name.git - Install the dependencies from root directory:
npm install - Rename
.env.exampleto.env - Now run:
npm run testornpm run test:watchornpm run coverage& see the results 🥳
See CHANGELOG.md.
rmq-pub-sub is licensed by MIT License.
Copyright © 2023 Md. Muhtasim Fuad Fahim
- Github: @mdmuhtasimfuadfahim
- LinkedIn: @mdmuhtasimfuadfahim