Interface ConsumerHandler

Parameters

• msg: AsyncMessage

  The incoming message
• reply: ((body: any, envelope?: 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
      • Optionalenvelope: Envelope

      Returns Promise<void>