fix(rabbitmq): return consumerTag when creating subscriber

packages/rabbitmq/src/amqp/connection.ts

@@ -424,21 +424,18 @@ export class AmqpConnection {
     consumeOptions?: ConsumeOptions
   ): Promise<SubscriptionResult> {
     return new Promise((res) => {
-      let result: SubscriptionResult;
-      this.selectManagedChannel(msgOptions?.queueOptions?.channel)
-        .addSetup(async (channel) => {
+      this.selectManagedChannel(msgOptions?.queueOptions?.channel).addSetup(
+        async (channel) => {
           const consumerTag = await this.setupSubscriberChannel<T>(
             handler,
             msgOptions,
             channel,
             originalHandlerName,
             consumeOptions
           );
-          result = { consumerTag };
-        })
-        .then(() => {
-          res(result);
-        });
+          res({ consumerTag });
+        }
+      );
     });
   }
 
@@ -532,20 +529,16 @@ export class AmqpConnection {
     rpcOptions: MessageHandlerOptions
   ): Promise<SubscriptionResult> {
     return new Promise((res) => {
-      let result: SubscriptionResult;
-      this.selectManagedChannel(rpcOptions?.queueOptions?.channel)
-        .addSetup(async (channel) => {
+      this.selectManagedChannel(rpcOptions?.queueOptions?.channel).addSetup(
+        async (channel) => {
           const consumerTag = await this.setupRpcChannel<T, U>(
             handler,
             rpcOptions,
             channel
           );
-          result = { consumerTag };
           res({ consumerTag });
-        })
-        .then(() => {
-          res(result);
-        });
+        }
+      );
     });
   }
 

packages/rabbitmq/src/tests/amqp.connection.spec.ts

@@ -0,0 +1,58 @@
+import { AmqpConnection } from '../amqp/connection';
+
+const mockConsumerTag = 'amq.ctag-mock';
+
+const mockChannel = 'mockChannel';
+const mockConfig = {
+  hostname: 'localhost',
+  port: 5672,
+  username: 'guest',
+  password: 'guest',
+  vhost: '/',
+  uri: 'amqp://guest:guest@localhost:5672/',
+};
+
+describe('AmqpConnection', () => {
+  let connection: AmqpConnection;
+
+  beforeEach(async () => {
+    jest
+      .spyOn(AmqpConnection.prototype as any, 'selectManagedChannel')
+      .mockReturnValue({
+        addSetup: jest.fn((callback) => callback(mockChannel)),
+      });
+    jest
+      .spyOn(AmqpConnection.prototype as any, 'setupSubscriberChannel')
+      .mockReturnValue(mockConsumerTag);
+    jest
+      .spyOn(AmqpConnection.prototype as any, 'setupRpcChannel')
+      .mockReturnValue(mockConsumerTag);
+
+    connection = new AmqpConnection(mockConfig);
+  });
+
+  it('should return consumer tag when resolves', async () => {
+    const mockHandler = jest.fn();
+    const mockMsgOptions = { queueOptions: { channel: mockChannel } };
+    const mockHandlerName = 'mockHandlerName';
+    const mockConsumeOptions = {};
+
+    const result = await connection.createSubscriber(
+      mockHandler,
+      mockMsgOptions,
+      mockHandlerName,
+      mockConsumeOptions
+    );
+
+    expect(result).toEqual({ consumerTag: mockConsumerTag });
+  });
+
+  it('should return consumer tag when resolves', async () => {
+    const mockHandler = jest.fn();
+    const mockRpcOptions = { queueOptions: { channel: mockChannel } };
+
+    const result = await connection.createRpc(mockHandler, mockRpcOptions);
+
+    expect(result).toEqual({ consumerTag: mockConsumerTag });
+  });
+});