From 2074db3e04b1fd32c03f9d0735d20ca25d21f162 Mon Sep 17 00:00:00 2001
From: Alvar San Martin <alvarsanmartin@savefamilygps.com>
Date: Tue, 27 Jan 2026 15:12:41 +0100
Subject: [PATCH] arreglada la creacion de queue-bindigs para el consumidor

---
 .../config/eventBusConfig.ts                  | 45 +++++++++++++------
 1 file changed, 31 insertions(+), 14 deletions(-)

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
 }