sf-sim/packages/sim-gestor-eventos/index.ts

import { env } from "#config/env"
import { RabbitConnection } from "#shared/adapters/queues/RabbitMQClient"

const rmqUser = env.RABBITMQ_USER
const rmqPass = env.RABBITMQ_PASSWORD
const rmqHost = env.RABBITMQ_HOST
const rmqPort = Number(env.RABBITMQ_PORT)
const rmqSecure = false
const rmqVhost = env.RABBITMQ_VHOST


console.log("[Generador] Iniciando")

async function test() {

  const rbmq = new RabbitConnection({
    username: rmqUser,
    password: rmqPass,
    vhost: String(rmqVhost),
    hostname: rmqHost,
    port: rmqPort,
    secure: rmqSecure
  })

  await rbmq.connect()

  console.log("[Generador] enviando --")

  rbmq.channel?.sendToQueue("sim.queue", Buffer.from("test"), {},
    function (err, ok) {
      if (err !== null)
        console.warn('Message nacked!');
      else
        console.log('Message acked');
    }
  )

}

test()

export default {}