23 lines
512 B
TypeScript
23 lines
512 B
TypeScript
|
|
import { startRMQClient } from "#config/eventBusConfig"
|
|
import { SimNosController } from "./aplication/SimNOS.controller.js"
|
|
|
|
async function startWorker() {
|
|
const rmqClient = await startRMQClient()
|
|
const simController = new SimNosController(
|
|
rmqClient
|
|
)
|
|
|
|
rmqClient.consume("sim.nos", simController.recibeMsg)
|
|
}
|
|
|
|
startWorker()
|
|
.then(e => {
|
|
console.log("[o] Worker de SIM de NOS iniciado")
|
|
})
|
|
.catch(e => {
|
|
console.log("[x] Error iniciando worker de SIM de NOS")
|
|
})
|
|
|
|
export default {}
|