feat(@nestjs/microservices): ack queue message make option in rabbitM…

…Q microservice nestjs#1583
underfin · Apr 20, 2019 · 102a345 · 102a345
1 parent ec14c92
commit 102a345
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 5 deletions.
diff --git a/packages/microservices/client/client-rmq.ts b/packages/microservices/client/client-rmq.ts
@@ -13,6 +13,7 @@ import {
   RQM_DEFAULT_QUEUE,
   RQM_DEFAULT_QUEUE_OPTIONS,
   RQM_DEFAULT_URL,
+  RQM_DEFAULT_NOACK
 } from './../constants';
 import { WritePacket } from './../interfaces';
 import { ClientProxy } from './client-proxy';
@@ -60,7 +61,10 @@ export class ClientRMQ extends ClientProxy {
         REPLY_QUEUE,
         (msg: any) =>
           this.responseEmitter.emit(msg.properties.correlationId, msg),
-        { noAck: true },
+          {
+            noAck: this.getOptionsProp<RmqOptions>(this.options, 'noAck') ||
+                RQM_DEFAULT_NOACK
+          }
       ),
     );
   }

diff --git a/packages/microservices/constants.ts b/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.`;

diff --git a/packages/microservices/interfaces/microservice-configuration.interface.ts b/packages/microservices/interfaces/microservice-configuration.interface.ts
@@ -1,7 +1,7 @@
-import { MqttClientOptions } from '@nestjs/common/interfaces/external/mqtt-options.interface';
-import { Transport } from '../enums/transport.enum';
-import { Server } from './../server/server';
-import { CustomTransportStrategy } from './custom-transport-strategy.interface';
+import {MqttClientOptions} from '@nestjs/common/interfaces/external/mqtt-options.interface';
+import {Transport} from '../enums/transport.enum';
+import {Server} from './../server/server';
+import {CustomTransportStrategy} from './custom-transport-strategy.interface';
 
 export type MicroserviceOptions =
   | GrpcOptions
@@ -94,5 +94,6 @@ export interface RmqOptions {
     isGlobalPrefetchCount?: boolean;
     queueOptions?: any;
     socketOptions?: any;
+    noAck?: boolean;
   };
 }