server.js 475 B

123456789101112131415
  1. const app = require('fastify')();
  2. const RabbitMQProducer = require('./utils/RabbitMQProducer');
  3. let rabbitMQProducer = new RabbitMQProducer();
  4. app.post('/', async (request, reply) => {
  5. try {
  6. await rabbitMQProducer.sendMessage('formatter', request.body.message);
  7. reply.send({ status: 'ok' });
  8. } catch (error) {
  9. console.error('Error handling POST request:', error);
  10. reply.status(500).send({ error: 'Internal Server Error' });
  11. }
  12. });
  13. module.exports = app;