fix(microservices): rmq should merge both disconnect and connect failed events

integration/microservices/e2e/disconnected-client.spec.ts

@@ -65,6 +65,19 @@ describe('Disconnected client', () => {
       .expect(408);
   });
 
+  it(`RMQ`, () => {
+    return request(server)
+      .post('/')
+      .send({
+        transport: Transport.RMQ,
+        options: {
+          urls: [`amqp://0.0.0.0:3333`],
+          queue: 'test',
+        },
+      })
+      .expect(408);
+  });
+
   afterEach(async () => {
     await app.close();
   });

integration/microservices/src/disconnected.controller.ts

@@ -15,12 +15,12 @@ export class DisconnectedClientController {
   call(@Body() options): Observable<number> {
     const client = ClientProxyFactory.create(options);
     return client.send<number, number[]>({ cmd: 'none' }, [1, 2, 3]).pipe(
-      /*tap(
-          console.log.bind(console, 'data'),
-          console.error.bind(console, 'error'),
-        ),*/
+      // tap(
+      //   console.log.bind(console, 'data'),
+      //   console.error.bind(console, 'error'),
+      // ),
       catchError(error => {
-        const { code } = error || { code: 'CONN_ERR' };
+        const { code } = error?.err ?? error ?? { code: 'CONN_ERR' };
         return throwError(() =>
           code === 'ECONNREFUSED' ||
           code === 'CONN_ERR' ||