Interface Channel

callback_api.d.ts:34–118

}

export interface Channel extends events.EventEmitter {
  readonly connection: Connection;

  on(event: 'close', listener: () => void): this;
  on(event: 'error', listener: (err: Error) => void): this;
  on(event: 'drain', listener: () => void): this;
  on(event: 'ack', listener: (fields: { deliveryTag: number; multiple: boolean }) => void): this;
  on(event: 'nack', listener: (fields: { deliveryTag: number; multiple: boolean; requeue: boolean }) => void): this;
  on(event: 'cancel', listener: (fields: { consumerTag: string }) => void): this;
  on(event: 'delivery', listener: (message: ConsumeMessage) => void): this;
  on(event: 'return', listener: (message: Message) => void): this;
  on(event: 'handler-error', listener: (err: Error, eventName: string) => void): this;
  on(event: string, listener: (...args: any[]) => void): this;

  close(callback?: (err: Error) => void): void;

  assertQueue(queue?: string, options?: Options.AssertQueue, callback?: (err: Error, ok: Replies.AssertQueue) => void): void;
  checkQueue(queue: string, callback?: (err: Error, ok: Replies.AssertQueue) => void): void;

  deleteQueue(queue: string, options?: Options.DeleteQueue, callback?: (err: Error, ok: Replies.DeleteQueue) => void): void;
  purgeQueue(queue: string, callback?: (err: Error, ok: Replies.PurgeQueue) => void): void;

  bindQueue(
    queue: string,
    source: string,
    pattern: string,
    args?: any,
    callback?: (err: Error, ok: Replies.Empty) => void,
  ): void;
  unbindQueue(
    queue: string,
    source: string,
    pattern: string,
    args?: any,
    callback?: (err: Error, ok: Replies.Empty) => void,
  ): void;

  assertExchange(
    exchange: string,
    type: 'direct' | 'topic' | 'headers' | 'fanout' | 'match' | string,
    options?: Options.AssertExchange,
    callback?: (err: Error, ok: Replies.AssertExchange) => void,
  ): void;
  checkExchange(exchange: string, callback?: (err: Error, ok: Replies.Empty) => void): void;

  deleteExchange(exchange: string, options?: Options.DeleteExchange, callback?: (err: Error, ok: Replies.Empty) => void): void;

  bindExchange(
    destination: string,
    source: string,
    pattern: string,
    args?: any,
    callback?: (err: Error, ok: Replies.Empty) => void,
  ): void;
  unbindExchange(
    destination: string,
    source: string,
    pattern: string,