class ClientRMQ extends ClientProxy {
  constructor(options: { urls?: string[] | RmqUrl[]; queue?: string; prefetchCount?: number; isGlobalPrefetchCount?: boolean; queueOptions?: AmqplibQueueOptions; socketOptions?: AmqpConnectionManagerSocketOptions; ... 13 more ...; maxConnectionAttempts?: number; })
  protected logger: Logger
  protected connection$: ReplaySubject<any>
  protected connectionPromise: Promise<void>
  protected client: AmqpConnectionManager | null
  protected channel: ChannelWrapper | null
  protected pendingEventListeners: Array<{...}
  protected isInitialConnect: true
  protected responseEmitter: EventEmitter
  protected queue: string
  protected queueOptions: Record<string, any>
  protected replyQueue: string
  protected noAssert: boolean
  protected options: Required<RmqOptions>['options']
  close(): Promise<void>
  connect(): Promise<any>
  createChannel(): Promise<void>
  createClient(): AmqpConnectionManager
  mergeDisconnectEvent<T = any>(instance: any, source$: Observable<T>): Observable<T>
  convertConnectionToPromise()
  setupChannel(channel: any, resolve: Function)
  consumeChannel(channel: any)
  registerErrorListener(client: any): void
  registerDisconnectListener(client: any): void
  on<EventKey extends keyof RmqEvents = keyof RmqEvents, EventCallback extends RmqEvents[EventKey] = RmqEvents[EventKey]>(event: EventKey, callback: EventCallback)
  unwrap<T>(): T
  handleMessage(packet: unknown, options: Record<string, unknown> | ((packet: WritePacket<any>) => any), callback?: (packet: WritePacket<any>) => any): Promise<void>
  protected publish(message: ReadPacket<any>, callback: (packet: WritePacket<any>) => any): () => void
  protected dispatchEvent(packet: ReadPacket<any>): Promise<any>
  protected initializeSerializer(options: { urls?: string[] | RmqUrl[]; queue?: string; prefetchCount?: number; isGlobalPrefetchCount?: boolean; queueOptions?: AmqplibQueueOptions; socketOptions?: AmqpConnectionManagerSocketOptions; ... 13 more ...; maxConnectionAttempts?: number; })
  protected mergeHeaders(requestHeaders?: Record<string, string>): Record<string, string> | undefined
  protected parseMessageContent(content: Buffer)

  // inherited from nest/packages/microservices/ClientProxy
  protected routingMap: Map<string, Function>
  protected serializer: ProducerSerializer
  protected deserializer: ProducerDeserializer
  protected _status$: ReplaySubject<Status>
  status: Observable<Status>
  abstract connect(): Promise<any>
  abstract close(): any
  on<EventKey extends keyof EventsMap = keyof EventsMap, EventCallback extends EventsMap[EventKey] = EventsMap[EventKey]>(event: EventKey, callback: EventCallback)
  abstract unwrap<T>(): T
  send<TResult = any, TInput = any>(pattern: any, data: TInput): Observable<TResult>
  emit<TResult = any, TInput = any>(pattern: any, data: TInput): Observable<TResult>
  protected abstract publish(packet: ReadPacket<any>, callback: (packet: WritePacket<any>) => void): () => void
  protected abstract dispatchEvent<T = any>(packet: ReadPacket<any>): Promise<T>
  protected createObserver<T>(observer: Observer<T>): (packet: WritePacket) => void
  protected serializeError(err: any): any
  protected serializeResponse(response: any): any
  protected assignPacketId(packet: ReadPacket<any>): ReadPacket & PacketId
  protected connect$(instance: any, errorEvent: string = 'error', connectEvent: string = 'connect'): Observable<any>
  protected getOptionsProp<Options extends ClientOptions['options'], Attribute extends keyof Options, DefaultValue extends Options[Attribute] = Options[Attribute]>(obj: Options, prop: Attribute, defaultValue: DefaultValue = undefined as DefaultValue)
  protected normalizePattern(pattern: MsPattern): string
  protected initializeSerializer(options: { url?: string; maxSendMessageLength?: number; maxReceiveMessageLength?: number; maxMetadataSize?: number; keepalive?: { keepaliveTimeMs?: number; keepaliveTimeoutMs?: number; keepalivePermitWithoutCalls?: number; http2MaxPingsWithoutData?: number; http2MinTimeBetweenPingsMs?: number; http2MinPingIntervalWithoutData...)
  protected initializeDeserializer(options: { url?: string; maxSendMessageLength?: number; maxReceiveMessageLength?: number; maxMetadataSize?: number; keepalive?: { keepaliveTimeMs?: number; keepaliveTimeoutMs?: number; keepalivePermitWithoutCalls?: number; http2MaxPingsWithoutData?: number; http2MinTimeBetweenPingsMs?: number; http2MinPingIntervalWithoutData...)
}

Constructor

constructor(options: { urls?: string[] | RmqUrl[]; queue?: string; prefetchCount?: number; isGlobalPrefetchCount?: boolean; queueOptions?: AmqplibQueueOptions; socketOptions?: AmqpConnectionManagerSocketOptions; ... 13 more ...; maxConnectionAttempts?: number; })

close(): Promise<void>

connect(): Promise<any>

createChannel(): Promise<void>

createClient(): AmqpConnectionManager

mergeDisconnectEvent<T = any>(instance: any, source$: Observable<T>): Observable<T>

convertConnectionToPromise()

setupChannel(channel: any, resolve: Function)

consumeChannel(channel: any)

registerErrorListener(client: any): void

registerDisconnectListener(client: any): void

on<EventKey extends keyof RmqEvents = keyof RmqEvents, EventCallback extends RmqEvents[EventKey] = RmqEvents[EventKey]>(event: EventKey, callback: EventCallback)

unwrap<T>(): T

handleMessage(packet: unknown, callback: (packet: WritePacket<any>) => any): Promise<void>

handleMessage(packet: unknown, options: Record<string, unknown>, callback: (packet: WritePacket<any>) => any): Promise<void>

protected publish(message: ReadPacket<any>, callback: (packet: WritePacket<any>) => any): () => void

protected dispatchEvent(packet: ReadPacket<any>): Promise<any>

protected initializeSerializer(options: { urls?: string[] | RmqUrl[]; queue?: string; prefetchCount?: number; isGlobalPrefetchCount?: boolean; queueOptions?: AmqplibQueueOptions; socketOptions?: AmqpConnectionManagerSocketOptions; ... 13 more ...; maxConnectionAttempts?: number; })

protected mergeHeaders(requestHeaders?: Record<string, string>): Record<string, string> | undefined

protected parseMessageContent(content: Buffer)