Method setupChannel

packages/microservices/client/client-rmq.ts:203–243

(channel: Channel, resolve: Function)

  }

  public async setupChannel(channel: Channel, resolve: Function) {
    const prefetchCount =
      this.getOptionsProp(this.options, 'prefetchCount') ||
      RQM_DEFAULT_PREFETCH_COUNT;
    const isGlobalPrefetchCount =
      this.getOptionsProp(this.options, 'isGlobalPrefetchCount') ||
      RQM_DEFAULT_IS_GLOBAL_PREFETCH_COUNT;

    if (!this.options.wildcards && this.options.exchangeType !== 'fanout') {
      if (!this.noAssert) {
        await channel.assertQueue(this.queue, this.queueOptions);
      }

      if (this.options.exchange && this.options.routingKey) {
        await channel.bindQueue(
          this.queue,
          this.options.exchange,
          this.options.exchangeType === 'fanout' ? '' : this.options.routingKey,
        );
      }
    } else {
      const exchange = this.getOptionsProp(
        this.options,
        'exchange',
        this.options.queue,
      );
      const exchangeType = this.getOptionsProp(
        this.options,
        'exchangeType',
        'topic',
      );
      await channel.assertExchange(exchange, exchangeType, {
        durable: true,
        arguments: this.getOptionsProp(this.options, 'exchangeArguments', {}),
      });
    }

    await channel.prefetch(prefetchCount, isGlobalPrefetchCount);
    await this.consumeChannel(channel);
    resolve();
  }

  public async consumeChannel(channel: Channel) {
    const noAck = this.getOptionsProp(this.options, 'noAck', RQM_DEFAULT_NOACK);