fix: only ack message if noAck option is false

tada5hi · Jun 12, 2024 · d6102e3 · d6102e3
1 parent fe2fd54
commit d6102e3
Showing 1 changed file with 9 additions and 3 deletions.
diff --git a/src/module.ts b/src/module.ts
@@ -112,16 +112,22 @@ export class Client {
                 handlers[ConsumeHandlerAnyKey];
 
             if (typeof handler === 'undefined') {
-                ch.nack(message, undefined, requeueOnFailure);
+                if (!options.noAck) {
+                    ch.nack(message, undefined, requeueOnFailure);
+                }
                 return;
             }
 
             try {
                 await handler(message, ch);
 
-                ch.ack(message);
+                if (!options.noAck) {
+                    ch.ack(message);
+                }
             } catch (e) {
-                ch.nack(message, undefined, requeueOnFailure);
+                if (!options.noAck) {
+                    ch.nack(message, undefined, requeueOnFailure);
+                }
             }
         };