Debug breaking tests

onebeyond · May 27, 2024 · 1551510 · 1551510
1 parent 42a11dc
commit 1551510
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/amqp/Subscription.js b/lib/amqp/Subscription.js
@@ -214,7 +214,7 @@ function Subscription(broker, vhost, subscriptionConfig, counter) {
     const previousXDeath = _.get(message, ['properties', 'headers', 'rascal', 'recovery', originalQueue, 'xDeath'], { count: 0 });
     const hasImmediateNackHeader = _.has(message, ['properties', 'headers', 'rascal', 'recovery', originalQueue, 'immediateNack']);
     if (!hasImmediateNackHeader) return false;
-    debug('Message %s has been marked for immediate nack', message.properties.messageId);
+    debug('Message %s has been marked for immediate nack. Previous xDeath is %o. Current xDeath is %o.', message.properties.messageId, previousXDeath, currentXDeath);
     if (currentXDeath.count === previousXDeath.count) return true;
     debug('Message %s has been replayed after being dead lettered. Removing immediate nack.', message.properties.messageId);
     _.unset(message, ['properties', 'headers', 'rascal', 'recovery', originalQueue, 'immediateNack']);