feature(microservices) added amqp-connection-manager

Author: AlariCode

integration/microservices/e2e/broadcast-rmq.spec.ts

@@ -20,18 +20,18 @@ describe('RabbitMQ transport', () => {
     app.connectMicroservice({
       transport: Transport.RMQ,
       options: {
-        url: `amqp://admin:admin@localhost`,
+        urls: [`amqp://admin:admin@localhost`],
         queue: 'test',
-        queueOptions: { durable: false }
-      }
+        queueOptions: { durable: false },
+      },
     });
     app.connectMicroservice({
       transport: Transport.RMQ,
       options: {
-        url: `amqp://admin:admin@localhost`,
+        urls: [`amqp://admin:admin@localhost`],
         queue: 'test',
-        queueOptions: { durable: false }
-      }
+        queueOptions: { durable: false },
+      },
     });
     await app.startAllMicroservicesAsync();
     await app.init();

integration/microservices/e2e/sum-rmq.spec.ts

@@ -19,10 +19,10 @@ describe('RabbimMQ transport', () => {
     app.connectMicroservice({
         transport: Transport.RMQ,
         options: {
-          url: `amqp://admin:admin@localhost`,
+          urls: [`amqp://admin:admin@localhost`],
           queue: 'test',
-          queueOptions: { durable: false }
-        }
+          queueOptions: { durable: false },
+        },
     });
     await app.startAllMicroservicesAsync();
     await app.init();

integration/microservices/src/rmq/rmq-broadcast.controller.ts

@@ -4,7 +4,7 @@ import {
   MessagePattern,
   ClientProxy,
   Transport,
-  ClientProxyFactory
+  ClientProxyFactory,
 } from '@nestjs/microservices';
 import { Observable } from 'rxjs';
 import { scan, take } from 'rxjs/operators';
@@ -17,10 +17,10 @@ export class RMQBroadcastController {
     this.client = ClientProxyFactory.create({
         transport: Transport.RMQ,
         options: {
-          url: `amqp://admin:admin@localhost`,
+          urls: [`amqp://admin:admin@localhost`],
           queue: 'test',
-          queueOptions: { durable: false }
-        }
+          queueOptions: { durable: false },
+        },
       });
   }
 

integration/microservices/src/rmq/rmq.controller.ts

@@ -4,7 +4,7 @@ import {
   MessagePattern,
   ClientProxy,
   Transport,
-  ClientProxyFactory
+  ClientProxyFactory,
 } from '@nestjs/microservices';
 import { Observable, of, from } from 'rxjs';
 import { scan } from 'rxjs/operators';
@@ -17,17 +17,16 @@ export class RMQController {
     this.client = ClientProxyFactory.create({
         transport: Transport.RMQ,
         options: {
-          url: `amqp://admin:admin@localhost`,
+          urls: [`amqp://admin:admin@localhost`],
           queue: 'test',
-          queueOptions: { durable: false }
-        }
+          queueOptions: { durable: false },
+        },
       });
   }
 
   @Post()
   @HttpCode(200)
   call(@Query('command') cmd, @Body() data: number[]) {
-    console.log(cmd, data)
     return this.client.send<number>({ cmd }, data);
   }