Class AMQPMessage

constructor

• new AMQPMessage(channel): AMQPMessage

• Parameters

  • channel: AMQPChannel

    Channel this message was delivered on

  Returns AMQPMessage

body

bodyPos

bodySize

channel

consumerTag

deliveryTag

exchange

Optional messageCount

properties

redelivered

Optional replyCode

Optional replyText

routingKey

ack

• ack(multiple?): Promise<void>

• Acknowledge the message

  Parameters

  • multiple: boolean = false

  Returns Promise<void>

bodyString

• bodyString(): null | string

• Returns null | string

bodyToString

• bodyToString(): null | string

• Converts the message (which is deliviered as an uint8array) to a string

  Returns null | string

cancelConsumer

• cancelConsumer(): Promise<AMQPChannel>

• Cancel the consumer the message arrived to *

  Returns Promise<AMQPChannel>

nack

• nack(requeue?, multiple?): Promise<void>

• Negative acknowledgment (same as reject)

  Parameters

  • requeue: boolean = false

  • multiple: boolean = false

  Returns Promise<void>

reject

• reject(requeue?): Promise<void>

• Rejected the message

  Parameters

  • requeue: boolean = false

  Returns Promise<void>