Class AMQPSubscription

constructor

• new AMQPSubscription(
      consumer: AMQPConsumer,
      def: ConsumerDefinition,
  ): AMQPSubscription
  Internal

  Parameters

  • consumer: AMQPConsumer
  • def: ConsumerDefinition

  Returns AMQPSubscription

Readonlydef

Optional InternalonCancel

channel

• get channel(): AMQPChannel

  The underlying channel. Reflects the most recent channel after a reconnect.

  Returns AMQPChannel

consumerTag

• get consumerTag(): string

  The consumer tag. Reflects the most recent tag after a reconnect.

  Returns string

cancel

• cancel(): Promise<void>

  Cancel the subscription and remove it from session auto-recovery. Safe to call on a closed channel.

  Returns Promise<void>

setConsumer

• setConsumer(consumer: AMQPConsumer): void
  Internal

  Swap in a new underlying consumer after reconnect.

  Parameters

  • consumer: AMQPConsumer

  Returns void