arreglada la creacion de queue-bindigs para el consumidor

This commit is contained in:
2026-01-27 15:12:41 +01:00
parent fe085cf128
commit 2074db3e04

View File

@@ -26,20 +26,37 @@ export async function startRMQClient() {
const channel = rabbitmqEventBus.channel const channel = rabbitmqEventBus.channel
// Bindings especificos, deberia meterlos en la clase // Bindings especificos, deberia meterlos en la clase
try { channel?.assertQueue("sim.objenious")
await rabbitmqEventBus.channel?.assertQueue("sim.objenious", {}) .then(e => {
console.log("[i] Las colas para objenious existen") console.log("[o] Creada la cola " + e.queue)
} catch (e) { channel?.bindQueue("sim.objenious", "sim.exchange", "sim.objenious.*")
console.log("[i] Cola de sims de objenious creada") .then(e => {
await channel?.bindQueue("sim.objenious", "sim.exchange", "sim.objenious.*") console.log("[o] Bindeada la cola sim.objenious a sim.exchange ")
} })
.catch(e => {
console.error(e)
})
})
.catch(e => {
console.error(e)
})
channel?.assertQueue("sim.objenious.dlx")
.then(e => {
console.log("[o] Creada la cola " + e.queue)
channel?.bindQueue("sim.objenious.dlx", "sim.dlx", "sim.objenious.*")
.then(e => {
console.log("[o] Bindeada la cola sim.objenious.dlx a sim.dlx")
})
.catch(e => {
console.error(e)
})
})
.catch(e => {
console.error(e)
})
try {
await rabbitmqEventBus.channel?.assertQueue("sim.dlx.objenious")
console.log("[i] Las colas dlx para objenious existen")
} catch (e) {
console.log("[i] Cola de dlx de objenious creada")
await channel?.bindQueue("sim.dlx.objenious", "sim.dlx", "sim.objenious.*")
}
return rabbitmqEventBus return rabbitmqEventBus
} }