Options
All
  • Public
  • Public/Protected
  • All
Menu

Interface SubscribeOptions

Hierarchy

  • SubscribeOptions

Index

Properties

Optional ack

ack: boolean

Default: false

Make it so that the AMQP server only delivers single messages at a time. When you want the next message, call queue.shift()

When false, you will receive messages as fast as they are emitted

Optional deliveryKeyInPayload

deliveryKeyInPayload: boolean

Default: undefined

Will inject the routingKey into the payload received

Optional exclusive

exclusive: boolean

Default: false

If set to true, only one subscriber is allowed at a time

Optional prefetchCount

prefetchCount: number

Default: 1

Will only send you N messages before you 'ack'.

Setting to zero will widen that window to 'unlimited'. If this is set, queue.shift() should not be used

Optional routingKeyInPayload

routingKeyInPayload: boolean

Default: undefined

Will inject the routingKey into the payload received

Generated using TypeDoc