Debug breaking tests

cressie176 · cressie176 · commit 48c0198c6106 · 2024-05-27T16:45:58.000+01:00
diff --git a/lib/amqp/Subscription.js b/lib/amqp/Subscription.js
@@ -97,7 +97,7 @@ function Subscription(broker, vhost, subscriptionConfig, counter) {
     decorateWithRoutingHeaders(message);
     if (immediateNack(message)) {
       debug('Immediately nacking message: %s from queue: %s', message.properties.messageId, config.queue);
-      ackOrNack(session, message, true);
+      ackOrNack(session, message, new Error('Immediate nack'));
       return;
     }
 

Original file line number	Diff line number	Diff line change
`@@ -97,7 +97,7 @@ function Subscription(broker, vhost, subscriptionConfig, counter) {`
`97`	`97`	`decorateWithRoutingHeaders(message);`
`98`	`98`	`if (immediateNack(message)) {`
`99`	`99`	`debug('Immediately nacking message: %s from queue: %s', message.properties.messageId, config.queue);`
`100`		`- ackOrNack(session, message, true);`
	`100`	`+ ackOrNack(session, message, new Error('Immediate nack'));`
`101`	`101`	`return;`
`102`	`102`	`}`
`103`	`103`