feat(microservices): support nats queue per handler

packages/microservices/server/server-nats.ts

@@ -77,16 +77,18 @@ export class ServerNats<
   }
 
   public bindEvents(client: Client) {
-    const queue = this.getOptionsProp(this.options, 'queue');
-    const subscribe = (channel: string) =>
+    const subscribe = (channel: string, queue: string) =>
       client.subscribe(channel, {
         queue,
         callback: this.getMessageHandler(channel).bind(this),
       });
 
+    const defaultQueue = this.getOptionsProp(this.options, 'queue');
     const registeredPatterns = [...this.messageHandlers.keys()];
     for (const channel of registeredPatterns) {
-      const sub = subscribe(channel);
+      const handlerRef = this.messageHandlers.get(channel);
+      const queue = handlerRef.extras?.queue ?? defaultQueue;
+      const sub = subscribe(channel, queue);
       this.subscriptions.push(sub);
     }
   }

packages/microservices/test/server/server-nats.spec.ts

@@ -113,11 +113,26 @@ describe('ServerNats', () => {
         [pattern]: messageHandler,
       });
     });
-    it('should subscribe to each acknowledge patterns', () => {
+
+    it('should subscribe to every pattern', () => {
       server.bindEvents(natsClient);
       expect(subscribeSpy.calledWith(pattern)).to.be.true;
     });
 
+    it('should use a per pattern queue if provided', () => {
+      const queue = 'test';
+      untypedServer.messageHandlers = objectToMap({
+        [pattern]: Object.assign(messageHandler, {
+          extras: {
+            queue,
+          },
+        }),
+      });
+      server.bindEvents(natsClient);
+      const lastCall = subscribeSpy.lastCall;
+      expect(lastCall.args[1].queue).to.be.eql(queue);
+    });
+
     it('should fill the subscriptions array properly', () => {
       server.bindEvents(natsClient);
       expect(server['subscriptions'].length).to.be.equals(1);