Interface Consumer

emitter

isClosed

isClosing

close

• close(): Promise<void>

• Wait for all current messages to finish and then close the consumer

  Returns Promise<void>

prefetch

• prefetch(prefetch): Empty

• Change the prefetch

  Parameters

  • prefetch: number

    Amount of messages to be unacked in the consumer

  Returns Empty