Merge branch 'underfin-rmq-options-noack'

Author: kamilmysliwiec

packages/microservices/client/client-rmq.ts

@@ -9,6 +9,7 @@ import {
   DISCONNECT_EVENT,
   ERROR_EVENT,
   RQM_DEFAULT_IS_GLOBAL_PREFETCH_COUNT,
+  RQM_DEFAULT_NOACK,
   RQM_DEFAULT_PREFETCH_COUNT,
   RQM_DEFAULT_QUEUE,
   RQM_DEFAULT_QUEUE_OPTIONS,
@@ -52,12 +53,16 @@ export class ClientRMQ extends ClientProxy {
   }
 
   public consumeChannel() {
+    const noAck =
+      this.getOptionsProp(this.options, 'noAck') || RQM_DEFAULT_NOACK;
     this.channel.addSetup((channel: any) =>
       channel.consume(
         REPLY_QUEUE,
         (msg: any) =>
           this.responseEmitter.emit(msg.properties.correlationId, msg),
-        { noAck: true },
+        {
+          noAck,
+        },
       ),
     );
   }

packages/microservices/constants.ts

@@ -24,6 +24,7 @@ export const RQM_DEFAULT_QUEUE = 'default';
 export const RQM_DEFAULT_PREFETCH_COUNT = 0;
 export const RQM_DEFAULT_IS_GLOBAL_PREFETCH_COUNT = false;
 export const RQM_DEFAULT_QUEUE_OPTIONS = {};
+export const RQM_DEFAULT_NOACK = true;
 export const GRPC_DEFAULT_PROTO_LOADER = '@grpc/proto-loader';
 
 export const NO_MESSAGE_HANDLER = `There is no matching message handler defined in the remote service.`;

packages/microservices/interfaces/microservice-configuration.interface.ts

@@ -94,5 +94,6 @@ export interface RmqOptions {
     isGlobalPrefetchCount?: boolean;
     queueOptions?: any;
     socketOptions?: any;
+    noAck?: boolean;
   };
 }