feat(rabbitmq): add publish options

libs/rabbitmq/src/RmqService.ts

@@ -1,21 +1,27 @@
 import { AmqpConnection } from '@golevelup/nestjs-rabbitmq';
 import { createLogger } from '@lsk4/log';
 import { Injectable } from '@nestjs/common';
+import { Options } from 'amqplib';
 
 import { RmqRequestPayload } from './types';
 
 @Injectable()
 export class RmqService {
   constructor(private readonly amqpConnection: AmqpConnection) {}
 
-  async publish(exchange: string, routingKey: string, payload: RmqRequestPayload) {
+  async publish(
+    exchange: string,
+    routingKey: string,
+    payload: RmqRequestPayload,
+    options?: Options.Publish,
+  ) {
     const { pattern, ...other } = payload || {};
     const ns = ['rmq:publish', exchange, routingKey].filter(Boolean).join(':');
     // TODO: add cache
     const log = createLogger(ns);
     log.trace(`[${pattern}]`, other);
     const time = Date.now();
-    const res = await this.amqpConnection.publish(exchange, routingKey, payload);
+    const res = await this.amqpConnection.publish(exchange, routingKey, payload, options);
     const ms = Date.now() - time;
     log.debug(`[${pattern}]`, other, res || 'OK', `${ms}ms`);
     return res;