diff --git a/packages/sim-consumidor-objenious/config/eventBusConfig.ts b/packages/sim-consumidor-objenious/config/eventBusConfig.ts index 74f4f33..b524d7e 100644 --- a/packages/sim-consumidor-objenious/config/eventBusConfig.ts +++ b/packages/sim-consumidor-objenious/config/eventBusConfig.ts @@ -26,20 +26,37 @@ export async function startRMQClient() { const channel = rabbitmqEventBus.channel // Bindings especificos, deberia meterlos en la clase - try { - await rabbitmqEventBus.channel?.assertQueue("sim.objenious", {}) - console.log("[i] Las colas para objenious existen") - } catch (e) { - console.log("[i] Cola de sims de objenious creada") - await channel?.bindQueue("sim.objenious", "sim.exchange", "sim.objenious.*") - } + channel?.assertQueue("sim.objenious") + .then(e => { + console.log("[o] Creada la cola " + e.queue) + channel?.bindQueue("sim.objenious", "sim.exchange", "sim.objenious.*") + .then(e => { + 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 }