Interface ConsumerHandler

Parameters

• msg: AsyncMessage

  The incoming message

• reply: ((body, envelope?) => Promise<void>)

  Reply to an RPC-type message. Like Channel#basicPublish() but the message body comes first. Some fields are also set automaticaly:

  • routingKey = msg.replyTo
  • exchange = ""
  • correlationId = msg.correlationId
  • • (body, envelope?): Promise<void>

    • Parameters

      • body: any

      • Optional envelope: Envelope

      Returns Promise<void>