def recv_msg(body,<EOL>message):
log.info(("<STR_LIT>"))<EOL>agg.handle_msg(<EOL>body=body,<EOL>org_message=message)<EOL>
recv_msg

    Handler method - fires when a messages is consumed from
    the ``FORWARD_QUEUE`` queue running in the ``FORWARD_BROKER_URL``
    broker.

    :param body: message body
    :param message: message object can ack, requeue or reject