Merge pull request #144 from blockful/dev

Dev

Author: LeonardoVieira1630

apps/consumers/src/services/ens-resolver.service.ts

@@ -15,7 +15,7 @@ export class EnsResolverService {
       chain: mainnet,
       transport: http(undefined, {
         timeout: 5_000,  // 5 seconds timeout
-        retryCount: 2,    // Try 2 times  
+        retryCount: 10,   // Try 10 times  
         retryDelay: 500   // Wait 500ms between retries
       })
     });

packages/rabbitmq-client/src/connections.ts

@@ -12,13 +12,22 @@ export class RabbitMQConnection {
     if (urlObj.hostname === 'localhost') {
       urlObj.hostname = '127.0.0.1';
     }
+    urlObj.searchParams.set('heartbeat', '30');
 
     this.url = urlObj.toString();
   }
 
   async connect(): Promise<void> {
     if (!this.connection) {
       this.connection = new Connection(this.url);
+      this.connection.on('error', (err) => {
+        console.error('[RabbitMQ] Connection error:', err.message);
+      });
+      
+      this.connection.on('connection', () => {
+        console.log('[RabbitMQ] Connection (re)established');
+      });
+      
       await this.connection.onConnect(5000);
     }
   }

packages/rabbitmq-client/src/consumer.ts

@@ -46,7 +46,7 @@ export class RabbitMQConsumer {
     );
 
     this.consumer.on('error', (err) => {
-      console.error('[RabbitMQConsumer] Consumer error:', err);
+      console.error(`[RabbitMQConsumer] Consumer error on queue '${this.queueName}':`, err.message);
     });
 
     this.isConsuming = true;

packages/rabbitmq-client/src/publisher.ts

@@ -27,7 +27,7 @@ export class RabbitMQPublisher {
 
       this.publisher = conn.createPublisher({
         confirm: true,
-        maxAttempts: 3,
+        maxAttempts: 10,
         exchanges: []
       });
     }