Send sync queue

FilasController.js

const amqp = require('amqplib');
const uuid = require('uuid');

module.exports = {
    async sendPublish (req, res) {
        const url = ``;
        const exchange = '';
        const routing_key = '';

        const conn = await amqp.connect(url);
        const channel = await conn.createChannel();
        await channel.assertExchange(exchange, 'direct', { durable: true });
        const q = await channel.assertQueue('', { exclusive: true });

        await channel.publish(
            exchange,
            routing_key,
            Buffer.from(
                JSON.stringify({
                    chave: 'provident',
                    cnpjCertificado: '54.117.372/0001-21',
                    idUsuario: '1',
                })
            ),
            {
                contentType: 'application/json',
                correlationId: uuid.v4(),
                replyTo: q.queue,
            }
        );

        let content = null;

        await channel.consume(
            q.queue,
            async data => {
                ({ content } = data);

                await channel.close();
                await conn.close();
            },
            { noAck: true }
        );

        const result = content ? JSON.parse(content.toString()) : {};

        return res.status(202).json(result);
    }
}