Debug breaking tests

onebeyond · May 27, 2024 · 11e751d · 11e751d
1 parent 3d6ae09
commit 11e751d
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/lib/amqp/Subscription.js b/lib/amqp/Subscription.js
@@ -95,9 +95,10 @@ function Subscription(broker, vhost, subscriptionConfig, counter) {
     session._incrementUnacknowledgeMessageCount(message.fields.consumerTag);
 
     decorateWithRoutingHeaders(message);
-    if (immediateNack(message)) return {
+    if (immediateNack(message)) {
       debug('Immediately nacking message: %s from queue: %s', message.properties.messageId, config.queue);
       ackOrNack(session, message, true);
+      return;
     }
 
     decorateWithRedeliveries(message, (err) => {