Descripcion

Paquete de Conexion para interceptar solicitudes Http y generar broadcast de solicitudes por el servicio de rabbitMQ

Instalacion

Instalacion del paquete

npm i ms-rabbit-cliente

Configuracion

Configuracion de Paquete en el archivo app.module.ts

import {AppModuleRabbitClient} from 'ms-rabbit-cliente'
@Module({
  imports: [
    AppModuleRabbitClient.register(),
  ],
  controllers: [], 
  providers: [],
})
export class AppModule {}

Configuracion de Paquete en el archivo my.montroller.ts

import { DatapassInterceptor } from 'ms-rabbit-cliente'

 @Get('/my-rest-api') 
 @SetMetadata("data-rabbit", {virtualHost:"server_client"}) 
 @UseInterceptors(RabbitInterceptor)
 async myRestApi(@Res({}) res) {
    try {
        const getResponse = await this.appService.myService()
        return getResponse
    } catch (error) {
        return res.status(HttpStatus.BAD_REQUEST).json(error);
    }
 }

Propiedades del decorador @SetMetadata("data-rabbit")

Descripcion de los campos en "data-cache"

| Propiedad | Valor | Descripcion | | ------ | ------ | ------ | | virtualHost | String (null) | Host Virtual donde creara una conexion, si este no existe lo creara automaticamete campo obligatorio| | sendAll | Boolean (true)| TRUE si se enviara a todos los queues dentro del virtualHost | | specifiedClient | String (null) | Si sendAll se establece en FALSO se debera ingresar de manera obligada el queue unico del cliente ||

Configuracion en la solicitud HTTP si se utilizara el interceptor

curl --location 'https://my-rest-api.com/rest-api-two?queue="queueUnique"

Uso del Servicio

Se pueden utilizar el servicio

Debe realizar la configuracion de Paquete en su archivo my.service.ts

import { RabbitServiceClient } from 'ms-rabbit-cliente';

@Injectable()
export class AppService {
  constructor(
    private rabbitServiceClient:RabbitServiceClient,
  ){}


  async getRestApiTWo():Promise<Observable<AxiosResponse<any[]>>>{
    try {
        this.rabbitServiceClient.sendDataVirtualHost({virtualHost:"server_client",sendAll:true},"queueUnique")
    } catch (error) {
        throw error
    }
  }
}

Descripcion de los objecto para envio de datos

| Propiedad | Valor | Descripcion | | ------ | ------ | ------ | | virtualHost | String (null) | Host Virtual donde creara una conexion, si este no existe lo creara automaticamete campo obligatorio| | sendAll | Boolean (true)| TRUE si se enviara a todos los queues dentro del virtualHost | | specifiedClient | String (null) | Si sendAll se establece en FALSO se debera ingresar de manera obligada el queue unico del cliente |

queueUnique Se recomienda colocar algun identificador unico de usuario o de conexion del cliente Vue