Loading packages/nest/rabbitmq/src/lib/client-rmq-exchange-module-options-factory.ts +8 −5 Original line number Diff line number Diff line import { ClientProvider, ClientsModuleOptionsFactory, } from '@nestjs/microservices'; import { ClientsModuleOptionsFactory } from '@nestjs/microservices'; import { CustomClientOptions } from '@nestjs/microservices/interfaces'; import { ClientRMQExchange } from './client-rmq-exchange'; import { ExchangeRmqOptions } from './options'; import { RabbitmqOptionsFactory } from './rabbitmq-options-factory'; export interface ClientRmqExchangeModuleOptions extends CustomClientOptions { options: ExchangeRmqOptions } export class ClientRmqExchangeModuleOptionsFactory extends RabbitmqOptionsFactory implements ClientsModuleOptionsFactory { async createClientOptions(exchange: string = this.config.getOrThrow('RABBITMQ_EXCHANGE')): Promise<ClientProvider> { async createClientOptions(exchange: string = this.config.getOrThrow('RABBITMQ_EXCHANGE')): Promise<ClientRmqExchangeModuleOptions> { const options = await this.build(); Loading Loading
packages/nest/rabbitmq/src/lib/client-rmq-exchange-module-options-factory.ts +8 −5 Original line number Diff line number Diff line import { ClientProvider, ClientsModuleOptionsFactory, } from '@nestjs/microservices'; import { ClientsModuleOptionsFactory } from '@nestjs/microservices'; import { CustomClientOptions } from '@nestjs/microservices/interfaces'; import { ClientRMQExchange } from './client-rmq-exchange'; import { ExchangeRmqOptions } from './options'; import { RabbitmqOptionsFactory } from './rabbitmq-options-factory'; export interface ClientRmqExchangeModuleOptions extends CustomClientOptions { options: ExchangeRmqOptions } export class ClientRmqExchangeModuleOptionsFactory extends RabbitmqOptionsFactory implements ClientsModuleOptionsFactory { async createClientOptions(exchange: string = this.config.getOrThrow('RABBITMQ_EXCHANGE')): Promise<ClientProvider> { async createClientOptions(exchange: string = this.config.getOrThrow('RABBITMQ_EXCHANGE')): Promise<ClientRmqExchangeModuleOptions> { const options = await this.build(); Loading