increase requeue attempts

repodiscover · Feb 21, 2020 · 6363bff · 6363bff
1 parent 964199b
commit 6363bff
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/lib/smtp-pool/index.js b/lib/smtp-pool/index.js
@@ -445,16 +445,18 @@ class SMTPPool extends EventEmitter {
     };
 
     _requeueEntryOnConnectionClose(connection) {
-        this.logger.debug(
+      connection.queueEntry.requeueAttempts = connection.queueEntry.requeueAttempts + 1;
+      this.logger.debug(
             {
                 tnx: 'pool',
                 cid: connection.id,
                 messageId: connection.queueEntry.messageId,
                 action: 'requeue'
             },
-            'Re-queued message <%s> for #%s',
+            'Re-queued message <%s> for #%s. Attempt: #%s',
             connection.queueEntry.messageId,
-            connection.id
+            connection.id,
+            connection.queueEntry.requeueAttempts;
         );
         this._queue.unshift(connection.queueEntry);
         connection.queueEntry = false;