| 123456789101112131415161718192021 |
- const fastify = require('fastify')();
- const RabbitMQProducer = require('./utils/RabbitMQProducer');
- let rabbitMQProducer = new RabbitMQProducer();
- fastify.post('/', async (request, reply) => {
- try {
- await rabbitMQProducer.sendMessage('formatter', request.body.message);
- reply.send({ status: 'Message Send' });
- } catch (error) {
- console.error('Error handling POST request:', error);
- reply.status(500).send({ error: 'Internal Server Error' });
- }
- });
- fastify.listen(8084, 'gateway', (err, address) => {
- if (err) {
- console.error(err);
- process.exit(1);
- }
- console.log(`Gateway api service workin on ${address}`);
- });
|