code: def recv_msg(body,
               message):
      
  
      log.info(("callback received msg "))
  
      agg.handle_msg(
          body=body,
          org_message=message)
docs: 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