code: def fetch_response(self, req_payload, **kwargs):
          
          if req_payload.uuid:
              uuids = set([req_payload.uuid, "CONNECT"])
              def callback(res_payload):
                  #pout.v(req_payload, res_payload)
                  #ret = req_payload.uuid == res_payload.uuid or res_payload.uuid == "CONNECT"
                  ret = res_payload.uuid in uuids
                  if ret:
                      logger.debug('{} received {} response for {}'.format(
                          self.client_id,
                          res_payload.code,
                          res_payload.uuid,
                      ))
                  return ret
  
              res_payload = self.recv_callback(callback, **kwargs)
  
          return res_payload
docs: payload has been sent, do anything else you need to do (eg, wait for response?)
  
          :param req_payload: Payload, the payload sent to the server
          :returns: Payload, the response payload