async getObservableWallets(txsAddresses: ITxsAddresses): Promise<ITxsAddresses> {
    try {
      const addresses = await this.walletMicroService.send({ cmd: 'wallet.getObservable.cua' }, txsAddresses)
      .pipe(
        timeout(5000),
        catchError(err => {
        if (err instanceof TimeoutError) {
          return throwError(new RequestTimeoutException());
        }
        return throwError(err);
      }),)
      .toPromise();

      return addresses;
    } catch (error) {
      console.log('getObservableWallets/error: ', error);
      throw new InternalServerErrorException(error);
    }
  }

  @MessagePattern({ cmd: `wallet.getObservable.nrg` })
  async getObservableWallets(@Payload(ValidationPipe) input: WalletGetObservableDto, @Ctx() context: NatsContext): Promise<WalletGetObservableRespDto | BadRequestException>{
    const subject = context.getSubject();
    const symbol = JSON.parse(subject).cmd.split('.')[2];
    const output = await this.internalMicroserviceService.getObservableWallets(input, symbol);

    return output;
  }