index.js 649 B

123456789101112131415161718192021
  1. const fastify = require('fastify')();
  2. const RabbitMQProducer = require('./utils/RabbitMQProducer');
  3. let rabbitMQProducer = new RabbitMQProducer();
  4. fastify.post('/', async (request, reply) => {
  5. try {
  6. await rabbitMQProducer.sendMessage('formatter', request.body.message);
  7. reply.send({ status: 'Message Send' });
  8. } catch (error) {
  9. console.error('Error handling POST request:', error);
  10. reply.status(500).send({ error: 'Internal Server Error' });
  11. }
  12. });
  13. fastify.listen(8084, 'gateway', (err, address) => {
  14. if (err) {
  15. console.error(err);
  16. process.exit(1);
  17. }
  18. console.log(`Gateway api service workin on ${address}`);
  19. });