Interface ConsumerHandler

Param: msg

The incoming message

Param: reply

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

routingKey = msg.replyTo
correlationId = msg.correlationId

interface ConsumerHandler ((msg, reply) => void | ConsumerStatus | Promise<void | ConsumerStatus>)

ConsumerHandler(msg, reply): void | ConsumerStatus | Promise<void | ConsumerStatus>
Parameters
- msg: AsyncMessage
- reply: ((body, envelope?) => Promise<void>)
  - - (body, envelope?): Promise<void>
    - Parameters
      body: any
      Optional envelope: Envelope
      Returns Promise<void>
Returns void | ConsumerStatus | Promise<void | ConsumerStatus>
- Defined in Consumer.ts:53

Generated using TypeDoc